スレッドの同期機構としてのモニター機能を提供するクラスです。 また同じスレッドから何度も lock できる Mutex としての機能も提供します。
require 'monitor'
buf = []
mon = Monitor.new
empty_cond = mon.new_cond
# consumer
Thread.start do
loop do
buf.synchronize do
empty_cond.wait_while { buf.empty? }
print buf.shift
end
end
end
# producer
while line = ARGF.gets
buf.synchronize do
buf.push(line)
empty_cond.signal
end
end
2回ロックしてもデッドロックにならない例です。
require 'monitor'
mon = Monitor.new
mon.synchronize {
mon.synchronize{
}
}
Mutex ではデッドロックになります。
require 'thread'
mx = Mutex.new
mx.synchronize {
mx.synchronize{
}
}
# => deadlock; recursive locking (ThreadError)
Monitor.newMonitor オブジェクトを生成します。
mon_enter
enterモニターをロックします。MonitorMixin#mon_enter を 参照して下さい。
mon_exit
exitモニターを解放します。MonitorMixin#mon_exit を 参照して下さい。
mon_synchronize { ... }
synchronize { ... }MonitorMixin#mon_synchronize を参照して下さい。
mon_try_enter
try_enterMonitorMixin#mon_try_enter を参照して下さい。
new_condMonitorMixin#new_cond を参照して下さい。