検索結果

Thread::ConditionVariable#signal -> self (6102.0)

• 2.1.0
• 2.2.0

• インスタンスメソッド

状態変数を待っているスレッドを1つ再開します。再開された スレッドは Thread::ConditionVariable#wait で指定した mutex のロックを試みます。

...ドは Thread::ConditionVariable#wait
で指定した mutex のロックを試みます。

@return 常に self を返します。

//emlist[例][ruby]{
mutex = Mutex.new
cv = ConditionVariable.new
flg = true

3.times {
Thread.start {
mutex.synchronize {
puts "a1"
while (flg)...

...cv.wait(mutex)
end
puts "a2"
}
}
}

Thread.start {
mutex.synchronize {
flg = false
cv.signal
}
}

sleep 1

# => a1
# => a1
# => a1
# => a2
//}...

• Thread::ConditionVariable

Thread::Queue#length -> Integer (6102.0)

• 2.1.0
• 2.2.0

• インスタンスメソッド

キューの長さを返します。

...キューの長さを返します。

//emlist[例][ruby]{
require 'thread'
q = Queue.new

[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }

q.length # => 4
//}...

• Thread::Queue

Thread::Queue#num_waiting -> Integer (6102.0)

• 2.1.0
• 2.2.0

• インスタンスメソッド

キューを待っているスレッドの数を返します。

...キューを待っているスレッドの数を返します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(1)
q.push(1)
t = Thread.new { q.push(2) }
sleep 0.05 until t.stop?
q.num_waiting # => 1

q.pop
t.join
//}...

• Thread::Queue

Thread::Queue#size -> Integer (3102.0)

• 2.1.0
• 2.2.0

• インスタンスメソッド

キューの長さを返します。

...キューの長さを返します。

//emlist[例][ruby]{
require 'thread'
q = Queue.new

[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }

q.length # => 4
//}...

• Thread::Queue

Thread::SizedQueue#max -> Integer (102.0)

• 2.1.0
• 2.2.0

• インスタンスメソッド

キューの最大サイズを返します。

キューの最大サイズを返します。

//emlist[例][ruby]{
q = SizedQueue.new(4)
q.max # => 4
//}

• Thread::SizedQueue

絞り込み条件を変える