スレッドの同期機構としてのモニター機能を提供するクラスです。 また同じスレッドから何度も 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)
mon_enterenterモニターをロックします。MonitorMixin#mon_enter を 参照して下さい。
mon_exitexitモニターを解放します。MonitorMixin#mon_exit を 参照して下さい。
mon_synchronize { ... }synchronize { ... }MonitorMixin#mon_synchronize を参照して下さい。
mon_try_entertry_enterMonitorMixin#mon_try_enter を参照して下さい。
new_condMonitorMixin#new_cond を参照して下さい。