Condition

Condition()函数用于创建条件变量对象，该对象在多线程并发环境中实现线程间的同步与通信。通过Condition()，线程可以在特定条件未满足时进入等待状态，直到其他线程发出条件满足的通知。

Condition()函数返回一个ThreadCondition对象。 ThreadCondition对象

Condition()

”`javascript function consumer(productionQuantity, dict, condition) { for (var i = 0; i < productionQuantity; i++) { condition.acquire() while (dict.get(“array”).length == 0) { condition.wait() } var arr = dict.get(“array”) var count = arr.shift() dict.set(“array”, arr) Log(“consumer:”, count, “, array:”, arr) condition.release() Sleep(1000) } }

function producer(productionQuantity, dict, condition) { for (var i = 0; i < productionQuantity; i++) { condition.acquire() var arr = dict.get(“array”) arr.push(i) dict.set(“array”, arr) Log(“producer:”, i, “, array:”, arr) condition.notify() condition.release() Sleep(1000) } }

function main() { var dict = threading.Dict() dict.set(“array”, []) var condition = threading.Condition() var productionQuantity = 10 var producerThread = threading.Thread(producer, productionQuantity, dict, condition) var consumerThread = threading.Thread(consumer, productionQuantity, dict, condition) consumerThread.join() producerThread.join() }“` 两个并发线程访问共享资源。

回测系统暂不支持此功能，仅提供接口定义。

{@fun/Threads/threading/getThread getThread}, {@fun/Threads/threading/mainThread mainThread}, {@fun/Threads/threading/currentThread currentThread}, {@fun/Threads/threading/Lock Lock}, {@fun/Threads/threading/Thread Thread}, {@fun/Threads/threading/Event Event}, {@fun/Threads/threading/Dict Dict}, {@fun/Threads/threading/pending pending}, {@fun/Threads/threading/eventLoop eventLoop}