検索結果

IO#wait(timeout = nil) -> bool | self | nil (54958.0)

• 2.1.0

• インスタンスメソッド

self が読み込み可能になるまでブロックし、読み込み可能になったら 真値を返します。タイムアウト、もしくはEOFで それ以上読みこめない場合は偽の値を返します。

self が読み込み可能になるまでブロックし、読み込み可能になったら
真値を返します。タイムアウト、もしくはEOFで
それ以上読みこめない場合は偽の値を返します。

より詳しくは、一度ブロックしてから読み込み可能になった場合には
selfを返します。
内部のバッファにデータがある場合には
ブロックせずに true を返します。
内部のバッファとはRubyの処理系が保持管理している
バッファのことです。

つまり、読み込み可能である場合にはtrueを返す場合と
selfを返す場合があることに注意してください。

timeout を指定した場合は、指定秒数経過するまでブロックし、タ
イムアウトし...

• IO

MonitorMixin::ConditionVariable#wait(timeout = nil) -> bool (54646.0)

• 2.1.0

• インスタンスメソッド

モニタのロックを開放し、現在のスレッドを停止します。

モニタのロックを開放し、現在のスレッドを停止します。

これを呼ぶスレッドはモニタのロックを保持している必要があります。

MonitorMixin::ConditionVariable#signal や
MonitorMixin::ConditionVariable#broadcast
で起こされるまでスレッドは停止し続けます。

timeout を与えた場合は最大 timeout 秒まで停止した後にスレッドを
再開します。

実行を再開したスレッドはモニタのロックを保持した状態になります。
これによって危険領域(critical section)上で動作している
スレッドはただ一つになり...

• MonitorMixin::ConditionVariable

Thread::ConditionVariable#wait(mutex, timeout = nil) -> self (54610.0)

• 2.1.0

• インスタンスメソッド

mutex のロックを解放し、カレントスレッドを停止します。 Thread::ConditionVariable#signalまたは、 Thread::ConditionVariable#broadcastで送られたシグナルを 受け取ると、mutexのロックを取得し、実行状態となります。

mutex のロックを解放し、カレントスレッドを停止します。
Thread::ConditionVariable#signalまたは、
Thread::ConditionVariable#broadcastで送られたシグナルを
受け取ると、mutexのロックを取得し、実行状態となります。

@param mutex Thread::Mutex オブジェクトを指定します。

@param timeout スリープする秒数を指定します。この場合はシグナルを受け取
らなかった場合でも指定した秒数が経過するとスリープを終了
します。省略する...

• Thread::ConditionVariable
• Thread::Mutex

ThreadsWait#next_wait(nonblock = nil) -> Thread (27628.0)

• 2.1.0

• インスタンスメソッド

指定したスレッドのどれかが終了するまで待ちます。

指定したスレッドのどれかが終了するまで待ちます。

@param nonblock true を与えると、キューが空の時、例外 ThreadsWait::ErrNoFinishedThread が発生します。

@raise ErrNoWaitingThread 終了をまつスレッドが存在しない時、発生します。

@raise ErrNoFinishedThread nonblock がtrue でかつ、キューが空の時、発生します。

#使用例
require 'thwait'

threads = []
2.times {|i|
threads << Thread.n...

• ThreadsWait
• ThreadsWait::ErrNoFinishedThread

IO#wait_readable(timeout = nil) -> bool | self | nil (18958.0)

• 2.1.0

• インスタンスメソッド

self が読み込み可能になるまでブロックし、読み込み可能になったら 真値を返します。タイムアウト、もしくはEOFで それ以上読みこめない場合は偽の値を返します。

self が読み込み可能になるまでブロックし、読み込み可能になったら
真値を返します。タイムアウト、もしくはEOFで
それ以上読みこめない場合は偽の値を返します。

より詳しくは、一度ブロックしてから読み込み可能になった場合には
selfを返します。
内部のバッファにデータがある場合には
ブロックせずに true を返します。
内部のバッファとはRubyの処理系が保持管理している
バッファのことです。

つまり、読み込み可能である場合にはtrueを返す場合と
selfを返す場合があることに注意してください。

timeout を指定した場合は、指定秒数経過するまでブロックし、タ
イムアウトし...

• IO

絞り込み条件を変える

IO#wait_writable(timeout) -> self | nil (18649.0)

• 2.1.0

• インスタンスメソッド

self が書き込み可能になるまでブロックし、書き込み可能になったら self を 返します。

self が書き込み可能になるまでブロックし、書き込み可能になったら self を
返します。

timeout を指定した場合は、指定秒数経過するまでブロックし、タイムアウト
した場合は nil を返します。

@param timeout タイムアウトまでの秒数を指定します。

@see IO#wait_readable

• IO

Net::Telnet#waitfor(opt) -> String|nil (18646.0)

• 2.1.0

• インスタンスメソッド

指定した正規表現にマッチする文字列がホストから来るまでデータを読み込みます。

指定した正規表現にマッチする文字列がホストから来るまでデータを読み込みます。

opt に正規表現を指定した場合には、それにマッチするまで読みこみます。
opt にハッシュを指定した場合には、以下のオプションを指定できます。

"Match" 待ち合わせたい正規表現を指定します。

"Prompt" "Match"と同じです。"Match"が指定されなかった場合にのみ使われます。

"String" "Match"と似ていますが、与えられた String のインスタンスに
完全に一致するデータを待ち合わせます。"Match"も"Prompt"も指定されなかった
場合にのみ利用されます。

"T...

• IOError
• Net::Telnet
• String

Net::Telnet#waitfor(opt) {|buf| ...} -> String|nil (18646.0)

• 2.1.0

• インスタンスメソッド

指定した正規表現にマッチする文字列がホストから来るまでデータを読み込みます。

指定した正規表現にマッチする文字列がホストから来るまでデータを読み込みます。

opt に正規表現を指定した場合には、それにマッチするまで読みこみます。
opt にハッシュを指定した場合には、以下のオプションを指定できます。

"Match" 待ち合わせたい正規表現を指定します。

"Prompt" "Match"と同じです。"Match"が指定されなかった場合にのみ使われます。

"String" "Match"と似ていますが、与えられた String のインスタンスに
完全に一致するデータを待ち合わせます。"Match"も"Prompt"も指定されなかった
場合にのみ利用されます。

"T...

• IOError
• Net::Telnet
• String

IO#wait_writable -> self (18349.0)

• 2.1.0

• インスタンスメソッド

self が書き込み可能になるまでブロックし、書き込み可能になったら self を 返します。

self が書き込み可能になるまでブロックし、書き込み可能になったら self を
返します。

timeout を指定した場合は、指定秒数経過するまでブロックし、タイムアウト
した場合は nil を返します。

@param timeout タイムアウトまでの秒数を指定します。

@see IO#wait_readable

• IO

IO#read_nonblock(maxlen, outbuf = nil, exception: true) -> String | Symbol | nil (646.0)

• 2.1.0

• インスタンスメソッド

IO をノンブロッキングモードに設定し、 その後で read(2) システムコールにより 長さ maxlen を上限として読み込み、文字列として返します。 EAGAIN, EINTR などは Errno::EXXX 例外として呼出元に報告されます。

IO をノンブロッキングモードに設定し、
その後で read(2) システムコールにより
長さ maxlen を上限として読み込み、文字列として返します。
EAGAIN, EINTR などは Errno::EXXX 例外として呼出元に報告されます。

発生した例外 がErrno::EAGAIN、 Errno::EWOULDBLOCK である場合は、
その例外オブジェクトに IO::WaitReadable が Object#extend
されます。

なお、バッファが空でない場合は、read_nonblock はバッファから読み込みます。この場合、read(2) システムコールは呼ばれません...

• Errno::EAGAIN
• Errno::EXXX
• IO
• IO::WaitReadable

絞り込み条件を変える

Socket#connect_nonblock(server_sockaddr) -> 0 (40.0)

• 2.1.0

• インスタンスメソッド

ソケットをノンブロッキングモードに設定した後、 connect(2) を呼び出します。

ソケットをノンブロッキングモードに設定した後、
connect(2) を呼び出します。

引数、返り値は Socket#connect と同じです。

connect が EINPROGRESS エラーを報告した場合、その例外(Errno::EINPROGRESS)
には IO::WaitWritable が Object#extend されます。
これを connect_nonblock をリトライするために使うことができます。

# Pull down Google's web page
require 'socket'
include Socket::Constants
...

• IO::WaitWritable
• Socket