361件ヒット
[1-100件を表示]
(0.070秒)
種類
- 定数 (231)
- インスタンスメソッド (75)
- クラス (22)
- 特異メソッド (18)
- 文書 (15)
クラス
- Thread (33)
- ThreadsWait (60)
モジュール
- Etc (231)
キーワード
-
CS
_ GNU _ LIBPTHREAD _ VERSION (11) -
CS
_ POSIX _ V7 _ THREADS _ CFLAGS (11) -
CS
_ POSIX _ V7 _ THREADS _ LDFLAGS (11) - ConditionVariable (11)
-
NEWS for Ruby 3
. 0 . 0 (4) -
SC
_ READER _ WRITER _ LOCKS (11) -
SC
_ THREADS (11) -
SC
_ THREAD _ ATTR _ STACKADDR (11) -
SC
_ THREAD _ ATTR _ STACKSIZE (11) -
SC
_ THREAD _ CPUTIME (11) -
SC
_ THREAD _ DESTRUCTOR _ ITERATIONS (11) -
SC
_ THREAD _ KEYS _ MAX (11) -
SC
_ THREAD _ PRIORITY _ SCHEDULING (11) -
SC
_ THREAD _ PRIO _ INHERIT (11) -
SC
_ THREAD _ PRIO _ PROTECT (11) -
SC
_ THREAD _ PROCESS _ SHARED (11) -
SC
_ THREAD _ ROBUST _ PRIO _ INHERIT (11) -
SC
_ THREAD _ ROBUST _ PRIO _ PROTECT (11) -
SC
_ THREAD _ SAFE _ FUNCTIONS (11) -
SC
_ THREAD _ SPORADIC _ SERVER (11) -
SC
_ THREAD _ STACK _ MIN (11) -
SC
_ THREAD _ THREADS _ MAX (11) -
SC
_ XOPEN _ REALTIME _ THREADS (11) - ThreadGroup (11)
-
all
_ waits (18) - empty? (6)
- finished? (6)
- join (28)
-
join
_ nowait (6) - new (6)
-
next
_ wait (6) -
ruby 1
. 8 . 4 feature (11) - value (11)
検索結果
先頭5件
-
ThreadsWait
# threads -> Array (30325.0) -
同期されるスレッドの一覧を配列で返します。
...ドの一覧を配列で返します。
使用例
require 'thwait'
threads = []
3.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
thall = ThreadsWait.new(*threads)
p thall.threads
#=> [#<Thread:0x21750 sleep>, #<Thread:0x216c4 sleep>, #<Thread:0x21638 sleep>]... -
Etc
:: SC _ THREAD _ THREADS _ MAX -> Integer (9403.0) -
Etc.#sysconf の引数に指定します。
Etc.#sysconf の引数に指定します。
詳細は sysconf(3) を参照してください。 -
ThreadsWait
. new(*threads) -> ThreadsWait (6525.0) -
指定されたスレッドの終了をまつための、スレッド同期オブジェクトをつくります。
...をつくります。
@param threads 終了を待つスレッドを一つもしくは複数指定します。
使用例
require 'thwait'
threads = []
5.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
thall = ThreadsWait.new(*threads)
thall.all_waits{|th|
pr......#=> #<Thread:0x214bc run>
#=> #<Thread:0x21548 run>
#=> #<Thread:0x215d4 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 d... -
ThreadsWait
. all _ waits(*threads) {|thread| . . . } -> () (6426.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.insp......#=> #<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 d... -
ThreadsWait
# join(*threads) -> () (6359.0) -
終了を待つスレッドの対象として、threads で指定されたスレッドを指定します。
...threads で指定されたスレッドを指定します。
@param threads 複数スレッドの終了を待つスレッドに指定されたthreadsを加えます。
require 'thwait'
threads = []
5.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
thall = ThreadsWai......t.new
p thall.threads #=> []
thall.join(*threads)
p thall.threads
#=> [#<Thread:0x216ec dead>, #<Thread:0x21660 dead>, #<Thread:0x215d4 dead>, #<Thread:0x214bc dead>]... -
ThreadsWait
# join _ nowait(*threads) -> () (6359.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) -> () (6326.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.insp......#=> #<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 d... -
Etc
:: SC _ THREADS -> Integer (6303.0) -
Etc.#sysconf の引数に指定します。
Etc.#sysconf の引数に指定します。
詳細は sysconf(3) を参照してください。 -
Etc
:: SC _ XOPEN _ REALTIME _ THREADS -> Integer (6303.0) -
Etc.#sysconf の引数に指定します。
Etc.#sysconf の引数に指定します。
詳細は sysconf(3) を参照してください。 -
Etc
:: CS _ POSIX _ V7 _ THREADS _ CFLAGS -> Integer (6302.0) -
Etc.#confstr の引数に指定します。
Etc.#confstr の引数に指定します。
詳細は confstr(3) を参照してください。 -
Etc
:: CS _ POSIX _ V7 _ THREADS _ LDFLAGS -> Integer (6302.0) -
Etc.#confstr の引数に指定します。
Etc.#confstr の引数に指定します。
詳細は confstr(3) を参照してください。 -
ThreadsWait
# next _ wait(nonblock = nil) -> Thread (6218.0) -
指定したスレッドのどれかが終了するまで待ちます。
... 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
# empty? -> bool (6130.0) -
同期されるスレッドが存在するならば true をかえします。
...ッドが存在するならば true をかえします。
使用例
require 'thwait'
threads = []
3.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
thall = ThreadsWait.new
p thall.threads.empty? #=> true
thall.join(*threads)
p thall.threads.empty? #=> false...