ライブラリ
クラス
- Exception (11)
- Fiber (22)
- IO (110)
- Monitor (37)
- Mutex (8)
- PStore (11)
- Socket (44)
- Thread (450)
-
Thread
:: Backtrace :: Location (44) -
Thread
:: ConditionVariable (33) -
Thread
:: Mutex (63) -
Thread
:: Queue (120) -
Thread
:: SizedQueue (75) - ThreadGroup (44)
- ThreadsWait (60)
- TracePoint (11)
-
YAML
:: Store (16)
モジュール
- Kernel (22)
- Marshal (22)
- MonitorMixin (11)
- Rake (11)
キーワード
-
1
. 6 . 8から1 . 8 . 0への変更点(まとめ) (11) - ConditionVariable (11)
- Enumerator (11)
- Fiber (11)
- Location (11)
- Monitor (11)
- MonitorMixin (11)
-
Mutex
_ m (9) -
NEWS for Ruby 2
. 0 . 0 (11) -
NEWS for Ruby 2
. 2 . 0 (10) -
NEWS for Ruby 2
. 3 . 0 (9) -
NEWS for Ruby 2
. 4 . 0 (8) -
NEWS for Ruby 2
. 5 . 0 (7) -
NEWS for Ruby 2
. 6 . 0 (6) -
NEWS for Ruby 2
. 7 . 0 (5) -
NEWS for Ruby 3
. 0 . 0 (4) -
NEWS for Ruby 3
. 1 . 0 (3) - Queue (11)
- Ruby用語集 (11)
- SizedQueue (11)
- Thread (11)
- ThreadGroup (11)
- WIN32OLE (11)
- [] (11)
-
abort
_ on _ exception (11) -
abort
_ on _ exception= (22) -
absolute
_ path (11) - add (11)
-
add
_ trace _ func (11) - alive? (11)
-
all
_ waits (18) - application= (11)
- backtrace (11)
-
backtrace
_ locations (33) -
base
_ label (11) - broadcast (11)
- clear (11)
- close (18)
- closed? (9)
- deq (22)
- drb (11)
-
drb
/ extservm (11) -
drb
/ gw (11) - dump (22)
- empty? (17)
- enclose (11)
- enclosed? (11)
- enter (11)
- eof (11)
- eof? (11)
- exit (22)
- fetch (7)
- finished? (6)
- fork (11)
-
handle
_ interrupt (11) -
ignore
_ deadlock= (3) - inspect (22)
- irb (11)
-
join
_ nowait (6) - kill (22)
- length (11)
- list (11)
- locked? (9)
- max (11)
- max= (11)
-
mon
_ enter (16) -
mon
_ exit (5) - name= (9)
-
net
/ imap (11) -
next
_ wait (6) -
num
_ waiting (11) - owned? (11)
- pass (11)
-
pending
_ interrupt? (11) - pipe (88)
- pop (22)
- priority (11)
- priority= (11)
- raise (11)
-
rb
_ thread _ s _ new (11) -
report
_ on _ exception (16) -
report
_ on _ exception= (16) - resolv (11)
- resume (11)
-
rinda
/ rinda (11) -
ruby 1
. 6 feature (11) -
ruby 1
. 8 . 3 feature (11) -
ruby 1
. 8 . 4 feature (11) -
ruby 1
. 8 . 5 feature (11) - run (11)
-
safe
_ level (7) -
set
_ trace _ func (11) - shift (22)
- signal (11)
- size (11)
- sleep (33)
- start (11)
- status (11)
- stop (11)
- stop? (11)
- synchronize (9)
-
tcp
_ server _ loop (22) - terminate (11)
-
thread
_ variable _ get (11) -
thread
_ variable _ set (11) - threads (6)
-
to
_ s (18) - transfer (11)
-
try
_ lock (9) - unix (22)
- unlock (11)
- value (11)
-
wait
_ for _ cond (5) - wakeup (11)
- yaml (11)
- スレッド (11)
- セキュリティモデル (11)
検索結果
先頭5件
-
Thread
. new(*arg) {|*arg| . . . } -> Thread (39226.0) -
スレッドを生成して、ブロックの評価を開始します。 生成したスレッドを返します。
...始と同時にその
スレッド固有のローカル変数に値を渡すために使用します。
@raise ThreadError 現在のスレッドが属する ThreadGroup が freeze されている場合に発生します。またブロックを与えられずに呼ばれた場合にも発......のコードは間違いです。スレッドの実行が開始される前に
変数 i が書き変わる可能性があるからです。
for i in 1..5
Thread.new { p i }
end
上の例は以下のように書き直すべきです。
for i in 1..5
Thread.new(i) {|t| p t }
end... -
Thread
# join -> self (39192.0) -
スレッド self の実行が終了するまで、カレントスレッドを停止し ます。self が例外により終了していれば、その例外がカレントス レッドに対して発生します。
...raise ThreadError join を実行することによってデッドロックが起きる場合に発生します。またカレントスレッドを join したときにも発生します。
以下は、生成したすべてのスレッドの終了を待つ例です。
threads = []
threads.pus......h(Thread.new { n = rand(5); sleep n; n })
threads.push(Thread.new { n = rand(5); sleep n; n })
threads.push(Thread.new { n = rand(5); sleep n; n })
threads.each {|t| t.join}... -
Thread
# join(limit) -> self | nil (39192.0) -
スレッド self の実行が終了するまで、カレントスレッドを停止し ます。self が例外により終了していれば、その例外がカレントス レッドに対して発生します。
...raise ThreadError join を実行することによってデッドロックが起きる場合に発生します。またカレントスレッドを join したときにも発生します。
以下は、生成したすべてのスレッドの終了を待つ例です。
threads = []
threads.pus......h(Thread.new { n = rand(5); sleep n; n })
threads.push(Thread.new { n = rand(5); sleep n; n })
threads.push(Thread.new { n = rand(5); sleep n; n })
threads.each {|t| t.join}... -
Thread (38178.0)
-
スレッドを表すクラスです。スレッドとはメモリ空間を共有して同時に実行される制御の流れです。 Thread を使うことで並行プログラミングが可能になります。
...スレッドを表すクラスです。スレッドとはメモリ空間を共有して同時に実行される制御の流れです。
Thread を使うことで並行プログラミングが可能になります。
=== 実装
ネイティブスレッドを用いて実装されていますが、......了するスレッドを Thread#join で待っている他の
スレッドがある場合、その待っているスレッドに対して、同じ例外が再度
発生します。
begin
t = Thread.new do
Thread.pass # メインスレッドが確実にjoinするように
raise......t や
Thread#status によって見ることができます。
p Thread.new {sleep 1} # => #<Thread:0xa039de0 sleep>
: run (実行or実行可能状態)
生成されたばかりのスレッドや Thread#run や
Thread#wakeup で起こされたスレッドはこの状態です。
Thread#join で... -
Thread
# thread _ variable _ get(key) -> object | nil (27221.0) -
引数 key で指定した名前のスレッドローカル変数を返します。
...注意]: Thread#[] でセットしたローカル変数(Fiber ローカル変数)と
異なり、Fiber を切り替えても同じ変数を返す事に注意してください。
例:
Thread.new {
Thread.current.thread_variable_set("foo", "bar") # スレッドローカル
Thread.current......ル
Fiber.new {
Fiber.yield [
Thread.current.thread_variable_get("foo"), # スレッドローカル
Thread.current["foo"], # Fiber ローカル
]
}.resume
}.join.value # => ['bar', nil]
この例の "bar" は Thread#thread_variable_get に......より得られ
た値で、nil はThread#[] により得られた値です。
@see Thread#thread_variable_set, Thread#[]
@see https://magazine.rubyist.net/articles/0041/0041-200Special-note.html... -
Thread
# thread _ variable _ set(key , value) (27191.0) -
引数 key で指定した名前のスレッドローカル変数に引数 value をセットしま す。
...]: Thread#[] でセットしたローカル変数(Fiber ローカル変数)と
異なり、セットした変数は Fiber を切り替えても共通で使える事に注意してく
ださい。
//emlist[例][ruby]{
thr = Thread.new do
Thread.current.thread_variable_set(:cat, 'meow')
Thread.c......urrent.thread_variable_set("dog", 'woof')
end
thr.join # => #<Thread:0x401b3f10 dead>
thr.thread_variables # => [:dog, :cat]
//}
@see Thread#thread_variable_get, Thread#[]... -
ThreadsWait
. new(*threads) -> ThreadsWait (21385.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... -
Thread
# abort _ on _ exception=(newstate) (21286.0) -
真の場合、そのスレッドが例外によって終了した時に、インタプリタ 全体を中断させます。false の場合、あるスレッドで起こった例 外は、Thread#join などで検出されない限りそのスレッ ドだけをなにも警告を出さずに終了させます。
...スレッドで起こった例
外は、Thread#join などで検出されない限りそのスレッ
ドだけをなにも警告を出さずに終了させます。
デフォルトは偽です。c:Thread#exceptionを参照してください。
@param newstate 自身を実行中に例外発生し......た場合、インタプリタ全体を終了させるかどうかを true か false で指定します。
//emlist[例][ruby]{
thread = Thread.new { sleep 1 }
thread.abort_on_exception # => false
thread.abort_on_exception = true
thread.abort_on_exception # => true
//}... -
ThreadGroup
. new -> ThreadGroup (21285.0) -
新たな ThreadGroup を生成して返します。
...たな ThreadGroup を生成して返します。
//emlist[例][ruby]{
thread_group = ThreadGroup.new
thread_group.add Thread.new { sleep 0.1; Thread.new { sleep 1 }; sleep 1 }
thread_group.add Thread.new { sleep 2 }
sleep 0.5
thread_group.list # => [#<Thread:0x007fc6f1842d70 sleep>, #<Thread:0x007......fc6f1842c80 sleep>, #<Thread:0x007fc6f080dba8 sleep>]
//}... -
ThreadsWait
# join(*threads) -> () (21273.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>]...