Threads 多线程

稳定性: 实验

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

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

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

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

threads

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

Thread.isAlive()

返回 {boolean}

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

Thread.waitFor()

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

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