402件ヒット
[401-402件を表示]
(0.184秒)
クラス
-
ARGF
. class (24) - BasicSocket (60)
- IO (60)
-
OpenSSL
:: SSL :: SSLSocket (48) - Socket (36)
- StringIO (36)
- TCPServer (12)
-
Thread
:: Queue (36) -
Thread
:: SizedQueue (36) - ThreadsWait (6)
- UDPSocket (12)
- UNIXServer (12)
モジュール
-
OpenSSL
:: Buffering (24)
キーワード
- accept (12)
-
accept
_ nonblock (48) - connect (12)
-
connect
_ nonblock (24) - deq (24)
- fcntl (12)
-
next
_ wait (6) - pop (24)
-
read
_ nonblock (48) - readpartial (24)
-
recv
_ nonblock (12) -
recvfrom
_ nonblock (24) - recvmsg (12)
-
recvmsg
_ nonblock (12) - sendmsg (12)
-
sendmsg
_ nonblock (12) - shift (24)
- syswrite (12)
-
write
_ nonblock (36)
検索結果
-
Thread
:: SizedQueue # pop(non _ block = false) -> object (3107.0) -
キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。
...ock true を与えると、キューが空の時に例外 ThreadError が発生します。
//emlist[例][ruby]{
require 'thread'
q = SizedQueue.new(4)
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}
th1......urce2
# resource3
//}
//emlist[例: nonblock = true][ruby]{
require 'thread'
q = SizedQueue.new(4)
th1 = Thread.start do
while 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
p e.m......essage
end
# => resource1
# resource2
# resource3
# => #<ThreadError: queue empty>
# => "queue empty"
//}
@see Thread::Queue#pop...