120件ヒット
[1-100件を表示]
（0.076秒）
:![[x]](/images/drop-condition-icon.png "条件を削除"){kind=icon}
:ライブラリ
- ビルトイン (84)
-
io
/ nonblock (12) - socket (12)
- thread (12)
クラス
- IO (36)
- Socket (12)
-
Thread
:: Queue (36) -
Thread
:: SizedQueue (36)
キーワード
-
connect
_ nonblock (12) - deq (24)
- pop (24)
-
read
_ nonblock (12) - shift (24)
-
write
_ nonblock (12)
検索結果
先頭5件
-
IO
# nonblock(bool = true) { . . . } -> object (18203.0) -
ブロック実行中、一時的に self のブロックモードを変更します。 bool が真ならノンブロックモード、偽ならブロックモードになります。
ブロック実行中、一時的に self のブロックモードを変更します。
bool が真ならノンブロックモード、偽ならブロックモードになります。
@param bool 真を指定するとノンブロックモード、偽を指定するとブロックモードになります。 -
Socket
# connect _ nonblock(server _ sockaddr) -> 0 (6126.0) -
ソケットをノンブロッキングモードに設定した後、 connect(2) を呼び出します。
...。
connect が EINPROGRESS エラーを報告した場合、その例外(Errno::EINPROGRESS)
には IO::WaitWritable が Object#extend されます。
これを connect_nonblock をリトライするために使うことができます。
# Pull down Google's web page
require 'socket'
inclu......(80, 'www.google.com')
begin # emulate blocking connect
socket.connect_nonblock(sockaddr)
rescue IO::WaitWritable
IO.select(nil, [socket]) # wait 3-way handshake completion
begin
socket.connect_nonblock(sockaddr) # check connection failure
rescue Errno::EISCONN
end
en... -
IO
# read _ nonblock(maxlen , outbuf = nil , exception: true) -> String | Symbol | nil (6120.0) -
IO をノンブロッキングモードに設定し、 その後で read(2) システムコールにより 長さ maxlen を上限として読み込み、文字列として返します。 EAGAIN, EINTR などは Errno::EXXX 例外として呼出元に報告されます。
...AGAIN、 Errno::EWOULDBLOCK である場合は、
その例外オブジェクトに IO::WaitReadable が Object#extend
されます。
なお、バッファが空でない場合は、read_nonblock はバッファから読み込みます。この場合、read(2) システムコールは呼ばれま......を返します。
@param maxlen 読み込む長さの上限を整数で指定します。
@param outbuf 文字列で指定します。IO#read_nonblock は読み込んだデータを outbuf に破壊的に格納し、
返り値は outbuf となります。outbuf は一旦 maxlen 長... -
IO
# write _ nonblock(string , exception: true) -> Integer | :wait _ writable (6114.0) -
IO をノンブロッキングモードに設定し、string を write(2) システムコールで書き出します。
...Errno::EAGAIN、 Errno::EWOULDBLOCK である場合は、
その例外オブジェクトに IO::WaitWritable が Object#extend
されます。よって IO::WaitWritable を write_nonblock のリトライが必要
かの判定に用いることができます。
@param string 自身に書き込み... -
Thread
:: Queue # deq(non _ block = false) -> object (110.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
...hile 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
while resource = q.pop
puts resource
end
end
[:resource1, :resour... -
Thread
:: Queue # pop(non _ block = false) -> object (110.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
...hile 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
while resource = q.pop
puts resource
end
end
[:resource1, :resour... -
Thread
:: Queue # shift(non _ block = false) -> object (110.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
...hile 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
while resource = q.pop
puts resource
end
end
[:resource1, :resour... -
Thread
:: SizedQueue # deq(non _ block = false) -> object (110.0) -
キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。
...ce
end
end
[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}
th1.join
# => resource1
# resource2
# resource3
//}
//emlist[例: nonblock = true][ruby]{
require 'thread'
q = SizedQueue.new(4)
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resource1,... -
Thread
:: SizedQueue # pop(non _ block = false) -> object (110.0) -
キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。
...ce
end
end
[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}
th1.join
# => resource1
# resource2
# resource3
//}
//emlist[例: nonblock = true][ruby]{
require 'thread'
q = SizedQueue.new(4)
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resource1,...