クエリ:thread > クエリ:join

606件ヒット [1-100件を表示] （0.032秒）

トップページ >

:thread

:join

別のキーワード

種類

ライブラリ

ビルトイン (366)
socket (33)
thread (20)
thwait (24)
win32ole (11)

クラス

キーワード

検索結果

<< 1 2 3 ... > >>

Thread#join -> self (27138.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 (27138.0)

インスタンスメソッド

...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}...

ThreadsWait#join(*threads) -> () (21243.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>]...

Thread#thread_variable_get(key) -> object | nil (15191.0)

インスタンスメソッド

引数 key で指定した名前のスレッドローカル変数を返します。

...注意]: Thread#[] でセットしたローカル変数(Fiber ローカル変数)と
異なり、Fiber を切り替えても同じ変数を返す事に注意してください。

例:

Thread.new {
Thread.current.thread_variable_set("foo", "bar") # スレッドローカル
Thread.current...

...
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) (15173.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#[]...

絞り込み条件を変える

static VALUE rb_thread_join_m(int argc, VALUE *argv, VALUE thread) (12300.0)

関数

static int rb_thread_join(rb_thread_t th, double limit) (12300.0)

関数

Thread::SizedQueue#deq(non_block = false) -> object (11042.0)

2.1.0
2.2.0

インスタンスメソッド

キューからひとつ値を取り出します。キューに push しようと待っているスレッドがあれば、実行を再開させます。

...ーが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}

th1.join
# => resource1
# resource2...

...e 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}

begin
th1.join
q.pop(true)
rescue => e
p e
p e.message
end

# => resource1
# resource2
# resource3
# => #<ThreadErr...

...or: queue empty>
# => "queue empty"
//}

@see Thread::Queue#pop...

Thread::SizedQueue#pop(non_block = false) -> object (11042.0)

2.1.0
2.2.0

インスタンスメソッド

キューからひとつ値を取り出します。キューに push しようと待っているスレッドがあれば、実行を再開させます。

...or: queue empty>
# => "queue empty"
//}

@see Thread::Queue#pop...

Thread::SizedQueue#shift(non_block = false) -> object (11042.0)

2.1.0
2.2.0

インスタンスメソッド

キューからひとつ値を取り出します。キューに push しようと待っているスレッドがあれば、実行を再開させます。

...or: queue empty>
# => "queue empty"
//}

@see Thread::Queue#pop...

絞り込み条件を変える

Thread::ConditionVariable (11036.0)

2.1.0
2.2.0

クラス

スレッドの同期機構の一つである状態変数を実現するクラスです。

...クラスです。

以下も ConditionVariable を理解するのに参考になります。

https://ruby-doc.com/docs/ProgrammingRuby/html/tut_threads.html#UF

=== Condition Variable とは

あるスレッド A が排他領域で動いていたとします。スレッド A は現在空いてい...

...tex = Mutex.new
cv = ConditionVariable.new

a = Thread.start {
mutex.synchronize {
...
while (条件が満たされない)
cv.wait(mutex)
end
...
}
}

b = Thread.start {
mutex.synchronize {
# 上の...

...th = Thread.new {
for obj in foods
q.send(obj)
print "sent ", obj, "\n"
end
q.send nil
}

l.push th

th = Thread.new {
while obj = q.recv
print "recv ", obj, "\n"
end
}
l.push th

l.each do |t|
t.join
end...

Thread::Queue#deq(non_block = false) -> object (11036.0)

2.1.0
2.2.0

インスタンスメソッド

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

...ューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = Queue.new

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}

th1.join
//}

//emlist[例: nonblock =...

...hread'

q = Queue.new

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}

begin
th1.join
q.pop(true)
rescue => e
p e
end

# => resource1
# resource2
# resource3
# => #<ThreadError: queue empty>
# => "q...

Thread::Queue#pop(non_block = false) -> object (11036.0)

2.1.0
2.2.0

インスタンスメソッド

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

Thread::Queue#shift(non_block = false) -> object (11036.0)

2.1.0
2.2.0

インスタンスメソッド

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

Thread::SizedQueue (11034.0)

2.1.0
2.2.0

クラス

サイズの最大値を指定できる Thread::Queue です。

...る Thread::Queue です。

=== 例

283 より。q をサイズ 1 の SizedQueue オブジェクトに
することによって、入力される行と出力される行が同じ順序になります。
q = [] にすると入力と違った順序で行が出力されます。

require 'thread'...

...q = SizedQueue.new(1)

th = Thread.start {
while line = q.pop
print line
end
}

while l = gets
q.push(l)
end
q.push(l)

th.join...

絞り込み条件を変える

Thread::Queue (11024.0)

2.1.0
2.2.0

クラス

Queue はスレッド間の FIFO(first in first out) の通信路です。スレッドが空のキューを読み出そうとすると停止します。キューになんらかの情報が書き込まれると実行は再開されます。

...サブクラス Thread::SizedQueue も提供されています。

=== 例

require 'thread'

q = Queue.new

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each{|r|
q.push(r)
}

th1.join

実行すると...

Thread::Queue#num_waiting -> Integer (11018.0)

2.1.0
2.2.0

インスタンスメソッド

キューを待っているスレッドの数を返します。

...キューを待っているスレッドの数を返します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(1)
q.push(1)
t = Thread.new { q.push(2) }
sleep 0.05 until t.stop?
q.num_waiting # => 1

q.pop
t.join
//}...

ThreadsWait#join_nowait(*threads) -> () (9249.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>]
# 実際には終了を待って...

Thread#[](name) -> object | nil (9138.0)

2.6.0
3.2

インスタンスメソッド

name に対応したスレッドに固有のデータを取り出します。 name に対応するスレッド固有データがなければ nil を返します。

...emlist[例][ruby]{
[
Thread.new { Thread.current["name"] = "A" },
Thread.new { Thread.current[:name] = "B" },
Thread.new { Thread.current["name"] = "C" }
].each do |th|
th.join
puts "#{th.inspect}: #{th[:name]}"
end

# => #<Thread:0x00000002a54220 dead>: A
# => #<Thread:0x00000002a541a8 d...

...0000002a54130 dead>: C
//}

Thread#[] と Thread#[]= を用いたスレッド固有の変数は
Fiber を切り替えると異なる変数を返す事に注意してください。

//emlist[][ruby]{
def meth(newvalue)
begin
oldvalue = Thread.current[:name]
Thread.current[:name] = newvalu...

...ume
p Thread.current[:name]
# => nil if fiber-local
# => 2 if thread-local (The value 2 is leaked to outside of meth method.)
//}

Fiber を切り替えても同じ変数を返したい場合は
Thread#thread_variable_get と Thread#thread_variable_set
を使用してください。

@see Thread#fet...

<< 1 2 3 ... > >>

別のキーワード

種類

ライブラリ

クラス

キーワード

検索結果

先頭5件

Thread#join -> self (27138.0)

Thread#join(limit) -> self | nil (27138.0)

ThreadsWait#join(*threads) -> () (21243.0)

Thread#thread_variable_get(key) -> object | nil (15191.0)

Thread#thread_variable_set(key, value) (15173.0)

static VALUE rb_thread_join_m(int argc, VALUE *argv, VALUE thread) (12300.0)

static int rb_thread_join(rb_thread_t th, double limit) (12300.0)

Thread::SizedQueue#deq(non_block = false) -> object (11042.0)

Thread::SizedQueue#pop(non_block = false) -> object (11042.0)

Thread::SizedQueue#shift(non_block = false) -> object (11042.0)

Thread::ConditionVariable (11036.0)

Thread::Queue#deq(non_block = false) -> object (11036.0)

Thread::Queue#pop(non_block = false) -> object (11036.0)

Thread::Queue#shift(non_block = false) -> object (11036.0)

Thread::SizedQueue (11034.0)

Thread::Queue (11024.0)

Thread::Queue#num_waiting -> Integer (11018.0)

ThreadsWait#join_nowait(*threads) -> () (9249.0)

Thread#[](name) -> object | nil (9138.0)