Threads
- threads.start(action)
- threads.shutDownAll()
- threads.currentThread()
- threads.disposable()
- threads.atomic([initialValue])
- threads.lock()
Thread
- Thread.interrupt()
- Thread.join([timeout])
- isAlive()
- waitFor()
- Thread.setTimeout(callback, delay[, …args])
- Thread.setInterval(callback, delay[, …args])
- Thread.setImmediate(callback[, …args])
- Thread.clearInterval(id)
- Thread.clearTimeout(id)
- Thread.clearImmediate(id)
线程安全
- sync(func)
线程通信

Threads#

Stability: 1 – Experiment

threads模块提供了多线程支持，可以启动新线程来运行脚本。

脚本主线程会等待所有子线程执行完成后才停止执行，因此如果子线程中有死循环，请在必要的时候调用exit()来直接停止脚本或threads.shutDownAll()来停止所有子线程。

通过threads.start()启动的所有线程会在脚本被强制停止时自动停止。

由于JavaScript自身没有多线程的支持，因此您可能会遇到意料之外的问题。

threads.start(action)#

action <Function> 要在新线程执行的函数
返回 Thread

启动一个新线程并执行action。

例如:

threads.start(function(){
    //在新线程执行的代码
    while(true){
        log("子线程");
    }
});
while(true){
    log("脚本主线程");
}

通过该函数返回的Thread对象可以获取该线程的状态，控制该线程的运行中。例如:

var thread = threads.start(function(){
    while(true){
        log("子线程");
    }
});
//停止线程执行
thread.interrupt();

更多信息参见Thread。

threads.shutDownAll()#

停止所有通过threads.start()启动的子线程。

threads.currentThread()#

返回 Thread

返回当前线程。

threads.disposable()#

返回 Disposable

新建一个Disposable对象，用于等待另一个线程的某个一次性结果。更多信息参见线程通信以及Disposable。

threads.atomic([initialValue])#

initialValue <number> 初始整数值，默认为0
返回AtomicLong

新建一个整数原子变量。更多信息参见线程安全以及AtomicLong。

threads.lock()#

返回ReentrantLock

新建一个可重入锁。更多信息参见线程安全以及ReentrantLock。

Thread#

线程对象，threads.start()返回的对象，用于获取和控制线程的状态，与其他线程交互等。

Thread对象提供了和timers模块一样的API，例如setTimeout(), setInterval()等，用于在该线程执行相应的定时回调，从而使线程之间可以直接交互。例如：

var thread = threads.start(function(){
    //在子线程执行的定时器
    setInterval(function(){
        log("子线程:" + threads.currentThread());
    }, 1000);
});

log("当前线程为主线程:" + threads.currentThread());

//等待子线程启动
thread.waitFor();
//在子线程执行的定时器
thread.setTimeout(function(){
    //这段代码会在子线程执行
    log("当前线程为子线程:" + threads.currentThread());
}, 2000);

sleep(30 * 1000);
thread.interrupt();

Thread.interrupt()#

中断线程运行。

Thread.join([timeout])#

timeout <number> 等待时间，单位毫秒

等待线程执行完成。如果timeout为0，则会一直等待直至该线程执行完成；否则最多等待timeout毫秒的时间。

例如:

var sum = 0;
//启动子线程计算1加到10000
var thread = threads.start(function(){
    for(var i = 0; i < 10000; i++){
        sum += i;
    }
});
//等待该线程完成
thread.join();
toast("sum = " + sum);

isAlive()#

返回 <boolean>

返回线程是否存活。如果线程仍未开始或已经结束，返回false; 如果线程已经开始或者正在运行中，返回true。

waitFor()#

等待线程开始执行。调用threads.start()以后线程仍然需要一定时间才能开始执行，因此调用此函数会等待线程开始执行；如果线程已经处于执行状态则立即返回。

var thread = threads.start(function(){
    //do something
});
thread.waitFor();
thread.setTimeout(function(){
    //do something
}, 1000);