285件ヒット
[1-100件を表示]
(0.016秒)
種類
- インスタンスメソッド (217)
- クラス (42)
- 特異メソッド (14)
- 文書 (12)
クラス
- Thread (3)
-
Thread
:: Queue (153) -
Thread
:: SizedQueue (75)
キーワード
- << (22)
- ClosedQueueError (9)
-
NEWS for Ruby 2
. 3 . 0 (9) -
NEWS for Ruby 3
. 1 . 0 (3) - SizedQueue (11)
- clear (11)
- close (18)
- closed? (9)
- deq (22)
- empty? (11)
- enq (22)
-
ignore
_ deadlock= (3) - length (11)
- new (14)
-
num
_ waiting (11) - pop (22)
- push (22)
- shift (22)
- size (11)
検索結果
先頭5件
-
Thread
:: Queue (41028.0) -
Queue はスレッド間の FIFO(first in first out) の通信路です。ス レッドが空のキューを読み出そうとすると停止します。キューになんら かの情報が書き込まれると実行は再開されます。
...Queue はスレッド間の FIFO(first in first out) の通信路です。ス
レッドが空のキューを読み出そうとすると停止します。キューになんら
かの情報が書き込まれると実行は再開されます。
最大サイズが指定できる Queue のサブクラ......ス Thread::SizedQueue も提供されています。
=== 例
require 'thread'
q = Queue.new
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}
th1.join
実行すると以下のよ... -
Queue (38032.0)
-
Alias of Thread::Queue
...Alias of Thread::Queue... -
Thread
:: Queue . new -> Thread :: Queue (24222.0) -
新しいキューオブジェクトを生成します。
...新しいキューオブジェクトを生成します。
@param items 初期値を Enumerable で指定します。
//emlist[][ruby]{
q = Queue.new
q = Queue.new([a, b, c])
q = Queue.new(items)
//}... -
Thread
:: Queue . new(items) -> Thread :: Queue (24222.0) -
新しいキューオブジェクトを生成します。
...新しいキューオブジェクトを生成します。
@param items 初期値を Enumerable で指定します。
//emlist[][ruby]{
q = Queue.new
q = Queue.new([a, b, c])
q = Queue.new(items)
//}... -
Thread
:: Queue . new -> Thread :: Queue (24202.0) -
新しいキューオブジェクトを生成します。
新しいキューオブジェクトを生成します。 -
Thread
:: Queue # close -> self (24066.0) -
キューを close します。close 済みのキューを再度 open することはできません。
...のように動作します。
* Thread::Queue#closed? は true を返します
* Thread::Queue#close は無視されます
* Thread::Queue#enq/push/<< は ClosedQueueError を発生します
* Thread::Queue#empty? が false を返す場合は Thread::Queue#deq/pop/shift は通常通りオブ......ジェクトを返します
また、ClosedQueueError は StopIteration を継承しているため、
close する事でループから脱出する事もできます。
例:
q = Queue.new
Thread.new{
while e = q.deq # wait for nil to break loop
# ...
end
}
q.close... -
Thread
:: Queue # deq(non _ block = false) -> object (24024.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
...例][ruby]{
require 'thread'
q = Queue.new
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}
th1.join
//}
//emlist[例: nonblock = true][ruby]{
require 'thread'
q = Queue.new
th1 = Thread.start do
wh......ile resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}
begin
th1.join
q.pop(true)
rescue => e
p e
end
# => resource1
# resource2
# resource3
# => #<ThreadError: queue empty>
# => "queue empty"
//}... -
Thread
:: Queue # pop(non _ block = false) -> object (24024.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
...例][ruby]{
require 'thread'
q = Queue.new
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}
th1.join
//}
//emlist[例: nonblock = true][ruby]{
require 'thread'
q = Queue.new
th1 = Thread.start do
wh......ile resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}
begin
th1.join
q.pop(true)
rescue => e
p e
end
# => resource1
# resource2
# resource3
# => #<ThreadError: queue empty>
# => "queue empty"
//}... -
Thread
:: Queue # shift(non _ block = false) -> object (24024.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
...例][ruby]{
require 'thread'
q = Queue.new
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}
th1.join
//}
//emlist[例: nonblock = true][ruby]{
require 'thread'
q = Queue.new
th1 = Thread.start do
wh......ile resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}
begin
th1.join
q.pop(true)
rescue => e
p e
end
# => resource1
# resource2
# resource3
# => #<ThreadError: queue empty>
# => "queue empty"
//}... -
Thread
:: Queue # clear -> () (24006.0) -
キューを空にします。返り値は不定です。
...キューを空にします。返り値は不定です。
//emlist[例][ruby]{
require 'thread'
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.length # => 4
q.clear
q.length # => 0
//}......キューを空にします。返り値は不定です。
//emlist[例][ruby]{
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.length # => 4
q.clear
q.length # => 0
//}... -
Thread
:: Queue # closed? -> bool (24006.0) -
キューが close されている時に true を返します。
...キューが close されている時に true を返します。
//emlist[例][ruby]{
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.closed? # => false
q.close
q.closed? # => true
//}... -
Thread
:: Queue # empty? -> bool (24006.0) -
キューが空の時、真を返します。
...キューが空の時、真を返します。
//emlist[例][ruby]{
q = Queue.new
q.empty? # => true
q.push(:resource)
q.empty? # => false
//}...