Suppose:
- 有一些对象(例如,一个数组
a
)和依赖于对象的条件(例如,a.empty?
).
- 当前线程以外的某些线程可以操作该对象(
a
),因此条件评估值的真实性会随着时间的推移而变化。
如何让当前线程在代码中的某个时刻休眠,并在条件满足时通过推送通知继续(唤醒)?
我不想像这样进行轮询:
...
sleep 1 until a.empty?
...
也许使用Fiber
将是一个线索。
也许我不太明白你的问题,但我想ConditionVariable
是解决此类问题的好方法。
So, ConditionVariable
可用于在发生某些情况时向线程发出信号。让我们来看看:
require 'thread'
a = [] # array a is empty now
mutex = Mutex.new
condvar = ConditionVariable.new
Thread.new do
mutex.synchronize do
sleep(5)
a << "Hey hey!"
# Now we have value in array; it's time to signal about it
condvar.signal
end
end
mutex.synchronize do
condvar.wait(mutex)
# This happens only after 5 seconds, when condvar recieves signal
puts "Hey. Array a is not empty now!"
end
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)