```Thread()```函数返回一个```Thread```对象，用于管理创建出的并发线程、线程通信等。
```Thread```对象
Thread(func, ...args)
Thread(...items)
参数```func```是用于并发执行的函数（通过引用传递），支持传入匿名函数。```func```可接受多个参数，这些参数将在并发执行时通过```...args```传入。因此，```func```的参数列表需要与```...args```一致。
func
true
function
参数```arg```是在回调执行时传递给```func```（即并发线程执行函数）的实际参数；参数```arg```可能有多个，```func```的参数列表需要与```...args```一致。
arg
false
string、number、bool、object、array、function、空值等系统支持的所有类型
参数```item```是一个数组，包含待并发执行的函数引用及其参数，调用```Thread```函数时的参数```item```可以传入多组。
item
true
array
```javascript
function test1(a, b, c) {
Log("test1:", a, b, c)
}
function main() {
var t1 = threading.Thread(test1, 1, 2, 3)
var t2 = threading.Thread(function (msg) {
Log("msg:", msg)
}, "Hello thread2")
t1.join()
t2.join()
}
Создание одновременной параллельной строки между пользовательской функцией и анонимной функцией.
function test1(msg) {
Log("msg:", msg)
test2("Hello test2")
}
function main() {
var t1 = threading.Thread(
[function(a, b, c) {Log(a, b, c)}, 1, 2, 3],
[test1, "Hello test1"],
[`function test2(msg) {Log("msg:", msg)}`])
t1.join()
}
ИспользованиеThread(...items)Форма для создания параллельных строк, выполняющих несколько функций в последовательности.
function testFunc1(p) {
Log("testFunc1 p:", p)
}
function main() {
threading.Thread(function(pfn) {
var threadName = threading.currentThread().name()
var threadId = threading.currentThread().id()
pfn(`in thread threadName: ${threadName}, threadId: ${threadId}`)
}, testFunc1).join()
}
Поддержка передачи параметров функциям, выполняющим функции одновременно.
function ml(input) {
const net = new brain.NeuralNetwork()
net.train([
{ input: [0, 0], output: [0] },
{ input: [0, 1], output: [1] },
{ input: [1, 0], output: [1] },
{ input: [1, 1], output: [0] },
])
return net.run(input)
}
function main() {
var ret = threading.Thread([ml, [1, 0]], [HttpQuery("https://unpkg.com/brain.js")]).join()
// ret: {"id":1,"terminated":false,"elapsed":337636000,"ret":{"0":0.9339330196380615}}
Log(ret)
}
Поддержка ввода цифровых строк, которые могут быть динамически импортированы в внешние библиотеки для одновременных вычислений.
ПроникновениеThread()Функции используются для одновременного выполнения функций.funcРаботает в изолированной среде, поэтому не может напрямую ссылаться на переменные, находящиеся за пределами потока, что приводит к компиляционным сбоям при ссылке. В то же время, в потоке не поддерживается ссылка на другие функции закрытия. Внутри потока можно вызвать все API, предоставляемые платформой, но нельзя вызвать другие функции, настроенные пользователем.
При завершении выполнения потока и отсутствии постоянного ссылки, основной слой системы автоматически восстанавливает ресурсы, связанные с потоком, без необходимости прямого вызова.join()Функция для освобождения ресурса. Если постоянные ссылки приводят к невозможности освобождения ресурса, количество одновременных релизов более 2000 сообщает ошибку:InternalError: too many routine wait, max is 2000。
Поддержка ретро-системы, дисковых условий; все функции, связанные с параллельными потоками, в ретро-системах поддерживаются только в качестве совместимости кода и фактически не выполняются параллельно.
{@fun/Threads/threading/getThread getThread}, {@fun/Threads/threading/mainThread mainThread}, {@fun/Threads/threading/currentThread currentThread}, {@fun/Threads/threading/Lock Lock}, {@fun/Threads/threading/Condition Condition}, {@fun/Threads/threading/Event Event}, {@fun/Threads/threading/Dict Dict}, {@fun/Threads/threading/pending pending}, {@fun/Threads/threading/eventLoop}
Настройки сети getThread