種類
ライブラリ
- ビルトイン (253)
-
io
/ wait (48) - monitor (42)
-
net
/ telnet (4) - open3 (168)
-
shell
/ builtin-command (6) -
shell
/ process-controller (30) -
shell
/ system-command (6) - socket (108)
- sync (24)
- syslog (12)
- thread (10)
- thwait (84)
- un (12)
クラス
-
ARGF
. class (10) - IO (72)
- Monitor (6)
-
MonitorMixin
:: ConditionVariable (36) -
Net
:: Telnet (4) -
Process
:: Status (12) -
Shell
:: BuiltInCommand (6) -
Shell
:: ProcessController (30) -
Shell
:: SystemCommand (6) - Socket (48)
-
Thread
:: ConditionVariable (36) -
Thread
:: Queue (22) - ThreadsWait (60)
モジュール
- Kernel (24)
- Open3 (168)
- Process (68)
-
RubyVM
:: MJIT (7) - Signal (24)
-
Socket
:: Constants (60) -
Sync
_ m (24) -
Syslog
:: Option (12)
キーワード
-
$ ? (12) -
1
. 6 . 8から1 . 8 . 0への変更点(まとめ) (12) - >> (12)
- ConditionVariable (12)
- ErrNoFinishedThread (6)
- ErrNoWaitingThread (6)
-
LOCAL
_ CONNWAIT (24) -
LOG
_ NOWAIT (12) -
MSG
_ DONTWAIT (24) -
MSG
_ PROXY (12) -
MSG
_ WAITALL (24) -
NEWS for Ruby 2
. 0 . 0 (12) -
NEWS for Ruby 2
. 2 . 0 (11) -
NEWS for Ruby 3
. 0 . 0 (5) -
NEWS for Ruby 3
. 1 . 0 (4) - Rubyの起動 (7)
- Status (12)
-
TCP
_ LINGER2 (12) - ThWait (6)
- ThreadsWait (6)
- WaitReadable (12)
- WaitWritable (12)
-
all
_ waits (18) - broadcast (12)
- close (10)
-
connect
_ nonblock (12) - empty? (6)
- finished? (6)
-
io
/ wait (12) - join (6)
-
join
_ nowait (6) -
last
_ status (8) - new (6)
-
next
_ wait (6) -
num
_ waiting (12) - pause (7)
-
pipeline
_ r (24) -
pipeline
_ rw (24) -
pipeline
_ start (24) -
pipeline
_ w (24) - popen2 (24)
- popen2e (24)
- popen3 (24)
-
rb
_ feature _ p (12) -
rb
_ thread _ polling (1) -
rb
_ thread _ schedule (12) -
rb
_ thread _ wait _ fd (12) -
rb
_ thread _ wait _ for (12) -
rb
_ thread _ wait _ other _ threads (12) -
read
_ nonblock (22) -
ruby 1
. 8 . 4 feature (12) - signal (12)
-
sync
_ upgrade _ waiting (6) -
sync
_ upgrade _ waiting= (6) -
sync
_ waiting (6) -
sync
_ waiting= (6) - threads (6)
- thwait (6)
- trap (24)
- wait2 (12)
- wait? (12)
-
wait
_ all _ jobs _ execution (6) -
wait
_ for _ cond (6) -
wait
_ readable (12) -
wait
_ to _ finish _ all _ process _ controllers (6) -
wait
_ until (12) -
wait
_ while (12) -
wait
_ writable (36) - waitall (12)
- waitfor (4)
-
waiting
_ job? (6) -
waiting
_ jobs (6) -
waiting
_ jobs _ exist? (6) - waitpid (12)
- waitpid2 (12)
-
write
_ nonblock (12)
検索結果
先頭5件
-
Process
. # wait(pid = -1 , flags = 0) -> Integer | nil (24236.0) -
pid で指定される特定の子プロセスの終了を待ち、そのプロセスが 終了した時に pid を返します。 wait2, waitpid2 は子プロセスの pid と終了ステータスを表す Process::Status オブジェクトの配列を返します。 ノンブロッキングモードで子プロセスがまだ終了していない時には nil を返します。
...定の子プロセスの終了を待ち、そのプロセスが
終了した時に pid を返します。
wait2, waitpid2 は子プロセスの pid と終了ステータスを表す
Process::Status オブジェクトの配列を返します。
ノンブロッキングモードで子プロセスが......まだ終了していない時には
nil を返します。
$? に終了した子プロセスの Process::Status オブジェクトがセットされます。
@param pid 子プロセスのプロセス ID を整数で指定します。
0 以上なら指定されたプロセス ID の子プ......とプロセスグループ ID が同じ任意の子プロセスを待ちます。
@param flags Process モジュールの定数 Process::WNOHANG(ノンブロッキングモード)と
Process::WUNTRACED の論理和を指定します。省略したときの値は 0 です。... -
MonitorMixin
:: ConditionVariable # wait(timeout = nil) -> bool (24213.0) -
モニタのロックを開放し、現在のスレッドを停止します。
...れを呼ぶスレッドはモニタのロックを保持している必要があります。
MonitorMixin::ConditionVariable#signal や
MonitorMixin::ConditionVariable#broadcast
で起こされるまでスレッドは停止し続けます。
timeout を与えた場合は最大 timeout 秒まで......によって危険領域(critical section)上で動作している
スレッドはただ一つになり、排他を実現します。
true を返します。timeout が与えられていて待ち時間が timeout を
越えた場合は false を返します。
@param timeout タイムアウトま......での秒数。指定しなかった場合はタイムアウトしません。
@raise ThreadError ロックを持っていないスレッドがこのメソッドを呼びだした場合に発生します
@see MonitorMixin::ConditionVariable#wait_while, MonitorMixin::ConditionVariable#wait_until... -
IO
# wait(timeout = nil) -> bool | self | nil (24208.0) -
self が読み込み可能になるまでブロックし、読み込み可能になったら 真値を返します。タイムアウト、もしくはEOFで それ以上読みこめない場合は偽の値を返します。
...timeout を指定した場合は、指定秒数経過するまでブロックし、タ
イムアウトした場合は nil を返します。
self が EOF に達していれば false を返します。
@param timeout タイムアウトまでの秒数を指定します。
@see IO#wait_writable... -
Thread
:: ConditionVariable # wait(mutex , timeout = nil) -> self (24201.0) -
mutex のロックを解放し、カレントスレッドを停止します。 Thread::ConditionVariable#signalまたは、 Thread::ConditionVariable#broadcastで送られたシグナルを 受け取ると、mutexのロックを取得し、実行状態となります。
...します。
Thread::ConditionVariable#signalまたは、
Thread::ConditionVariable#broadcastで送られたシグナルを
受け取ると、mutexのロックを取得し、実行状態となります。
@param mutex Thread::Mutex オブジェクトを指定します。
@param timeout スリー......ます。この場合はシグナルを受け取
らなかった場合でも指定した秒数が経過するとスリープを終了
します。省略するとスリープし続けます。
@see Thread::ConditionVariable#signal, Thread::ConditionVariable#broadcast......停止します。
Thread::ConditionVariable#signalまたは、
Thread::ConditionVariable#broadcastで送られたシグナルを
受け取ると、mutexのロックを取得し、実行状態となります。
@param mutex Mutex オブジェクトを指定します。
@param timeout スリープ... -
static void rb
_ thread _ wait _ other _ threads(void) (18200.0) -
-
ThreadsWait
:: ErrNoWaitingThread (18006.0) -
終了を待つスレッドが存在しない時、発生します。
...終了を待つスレッドが存在しない時、発生します。
@see ThreadsWait#next_wait... -
ThreadsWait
# next _ wait(nonblock = nil) -> Thread (15207.0) -
指定したスレッドのどれかが終了するまで待ちます。
...まで待ちます。
@param nonblock true を与えると、キューが空の時、例外 ThreadsWait::ErrNoFinishedThread が発生します。
@raise ErrNoWaitingThread 終了をまつスレッドが存在しない時、発生します。
@raise ErrNoFinishedThread nonblock がtrue でかつ......、キューが空の時、発生します。
#使用例
require 'thwait'
threads = []
2.times {|i|
threads << Thread.new { sleep i }
}
thall = ThreadsWait.new
thall.join_nowait(*threads)
until thall.empty?
th = thall.next_wait
p th
end
@see Queue#pop... -
ThreadsWait
# all _ waits -> () (15200.0) -
指定されたスレッドすべてが終了するまで待ちます。 ブロックが与えられた場合、スレッド終了時にブロックを評価します。
...uire 'thwait'
threads = []
5.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
thall = ThreadsWait.new(*threads)
thall.all_waits{|th|
printf("end %s\n", th.inspect)
}
# 出力例
#=> #<Thread:0x214bc run>
#=> #<Thread:0x21548 run>
#=> #<Thread:0x215d......4 run>
#=> #<Thread:0x21660 run>
#=> #<Thread:0x21430 run>
#=> end #<Thread:0x214bc dead>
#=> end #<Thread:0x21548 dead>
#=> end #<Thread:0x215d4 dead>
#=> end #<Thread:0x21660 dead>
#=> end #<Thread:0x21430 dead>... -
ThreadsWait
# join _ nowait(*threads) -> () (15200.0) -
終了を待つスレッドの対象として、threads で指定されたスレッドを指定します。 しかし、実際には終了をまちません。
...、threads で指定されたスレッドを指定します。
しかし、実際には終了をまちません。
@param threads 複数スレッドの終了を待つスレッドに指定されたthreadsを加えます。
require 'thwait'
threads = []
5.times {|i|
threads << Thread.new......{ sleep 1; p Thread.current }
}
thall = ThreadsWait.new
p thall.threads #=> []
thall.join_nowait(*threads)
p thall.threads #=> [#<Thread:0x21638 sleep>, #<Thread:0x215ac sleep>, #<Thread:0x21520 sleep>, #<Thread:0x21494 sleep>, #<Thread:0x21408 sleep>]
# 実際には終了を待って... -
ThreadsWait
. all _ waits(*threads) -> () (15200.0) -
指定されたスレッドすべてが終了するまで待ちます。 ブロックが与えられた場合、スレッド終了時にブロックを評価します。
...ックを評価します。
@param threads 終了するまでまつスレッドを一つもしくは複数指定します。
require 'thwait'
threads = []
5.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
ThreadsWait.all_waits(*threads) {|th| printf("end %s\n", th.i......#<Thread:0x21584 run>
#=> #<Thread:0x21610 run>
#=> #<Thread:0x2169c run>
#=> #<Thread:0x21728 run>
#=> #<Thread:0x214f8 run>
#=> end #<Thread:0x21584 dead>
#=> end #<Thread:0x21610 dead>
#=> end #<Thread:0x2169c dead>
#=> end #<Thread:0x21728 dead>
#=> end #<Thread:0x214f8 dead>... -
ThreadsWait
. all _ waits(*threads) {|thread| . . . } -> () (15200.0) -
指定されたスレッドすべてが終了するまで待ちます。 ブロックが与えられた場合、スレッド終了時にブロックを評価します。
...ックを評価します。
@param threads 終了するまでまつスレッドを一つもしくは複数指定します。
require 'thwait'
threads = []
5.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
ThreadsWait.all_waits(*threads) {|th| printf("end %s\n", th.i......#<Thread:0x21584 run>
#=> #<Thread:0x21610 run>
#=> #<Thread:0x2169c run>
#=> #<Thread:0x21728 run>
#=> #<Thread:0x214f8 run>
#=> end #<Thread:0x21584 dead>
#=> end #<Thread:0x21610 dead>
#=> end #<Thread:0x2169c dead>
#=> end #<Thread:0x21728 dead>
#=> end #<Thread:0x214f8 dead>... -
Sync
_ m # sync _ upgrade _ waiting -> [Thread] (12300.0) -
@todo
@todo