class Thread::Monitor (Ruby 4.1 リファレンスマニュアル)

aliases: Monitor

要約

スレッドの同期機構としてのモニター機能を提供するクラスです。また同じスレッドから何度も lock できる Mutex としての機能も提供します。

Ruby 4.0 までは monitor ライブラリの Monitor クラスとして提供されていましたが、Ruby 4.1 で組み込みクラスになりました。Monitor は Thread::Monitor の別名として引き続き使えます。

MonitorMixin と、mon_enter のような mon_ の付いた別名メソッドは、引き続き monitor ライブラリで定義されています(RubyGems が読み込むため、通常は require しなくても使えます)。

例

消費者、生産者問題の例

buf = []
mon = Thread::Monitor.new
empty_cond = mon.new_cond

# consumer
Thread.start do
  loop do
    mon.synchronize do
      empty_cond.wait_while { buf.empty? }
      print buf.shift
    end
  end
end

# producer
while line = ARGF.gets
  mon.synchronize do
    buf.push(line)
    empty_cond.signal
  end
end

2回ロックしてもデッドロックにならない例です。

デッドロックにならない例

mon = Thread::Monitor.new
mon.synchronize {
  mon.synchronize {
  }
}

Thread::Mutex ではデッドロックになります。

Mutex でデッドロックになる例

mx = Mutex.new
mx.synchronize {
  mx.synchronize {
  }
}
# => deadlock; recursive locking (ThreadError)

特異メソッド

new -> Thread::Monitor[permalink][rdoc][edit]: 新しい Thread::Monitor オブジェクトを生成します。

インスタンスメソッド

enter -> ()[permalink][rdoc][edit]

mon_enter -> ()

モニターをロックします。

一度に一つのスレッドだけがモニターをロックできます。既にモニターがロックされている場合は、ロックが開放されるまでそのスレッドは待ちます。

Thread::Mutex#lock に相当します。 Thread::Mutex#lock と違うのは現在のモニターの所有者が現在実行されているスレッドである場合、何度でもロックできる点です。ロックした回数だけ Thread::Monitor#exit を呼ばなければモニターは解放されません。

例

mon = Thread::Monitor.new
mon.enter
mon.enter

Thread::Mutex#lock ではデッドロックが起きます。

Mutex でデッドロックする例

m = Mutex.new
m.lock
m.lock # => deadlock; recursive locking (ThreadError)

exit -> ()[permalink][rdoc][edit]

mon_exit -> ()

モニターのロックを解放します。

enter でロックした回数だけ exit を呼ばなければモニターは解放されません。

モニターが解放されればモニターのロック待ちになっていたスレッドが一つ実行を再開します。

[EXCEPTION] ThreadError:: ロックを持っていないスレッドが呼びだした場合に発生します

例

mon = Thread::Monitor.new
mon.enter
mon.enter
mon.exit
mon.exit
mon.exit # => current thread not owner (ThreadError)

mon_check_owner -> nil[permalink][rdoc][edit]

MonitorMixin 用の内部メソッドです。

[EXCEPTION] ThreadError:: ロックを持っていないスレッドが呼びだした場合に発生します

mon_locked? -> boolRuby 2.5.0 から[permalink][rdoc][edit]

モニターがロックされているときに true を返します。

mon_owned? -> boolRuby 2.5.0 から[permalink][rdoc][edit]

カレントスレッドがモニターをロックしているときに true を返します。

synchronize { ... } -> object[permalink][rdoc][edit]

mon_synchronize { ... } -> object

モニターをロックし、ブロックを実行します。実行後に必ずモニターのロックを解放します。

ブロックの評価値を返り値として返します。

[SEE_ALSO] Thread::Monitor#enter

try_enter -> bool[permalink][rdoc][edit]

try_mon_enter -> bool

mon_try_enter -> bool

モニターのロックを取得しようと試みます。ロックに成功した(ロックが開放状態だった、もしくはロックを取得していたスレッドが自分自身であった)場合には真を返します。

ロックができなかった場合は偽を返し、実行を継続します。この場合にはスレッドはブロックしません。

new_cond -> Thread::Monitor::ConditionVariable[permalink][rdoc][edit]

モニターに関連付けられた、新しい Thread::Monitor::ConditionVariable を生成して返します。

wait_for_cond(cond, timeout) -> boolRuby 2.7.0 から[permalink][rdoc][edit]

Thread::Monitor::ConditionVariable 用の内部メソッドです。

[PARAM] cond:: Thread::ConditionVariable を指定します。
[PARAM] timeout:: タイムアウトまでの秒数。指定しなかった場合はタイムアウトしません。
[RETURN]: タイムアウトしたときは false を返します。それ以外は true を返します。

例

m = Thread::Monitor.new
cv = Thread::ConditionVariable.new
m.enter
m.wait_for_cond(cv, 1)

要約

例

目次

特異メソッド

インスタンスメソッド