threads - 多线程

约 2356 字大约 8 分钟老猫

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对象，用于等待另一个线程的某个一次性结果。更多信息参见线程通信。

threads.atomic([initialValue])

initialValue {number} 初始整数值，默认为0
返回 { AtomicLong open in new window }

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

threads.lock()

返回 { ReentrantLock open in new window }

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

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);