クエリ:r > クエリ:thread > バージョン:2.7.0

Rubyで実装されたタプルスペース(Tuple Space)を扱うためのライブラリです。

タプルスペースとは並列プログラムにおける一つのパターンです。
並列プログラミングにおいては、ロックのような同期処理が必須ですが、
適切な同期処理を実現することは困難をともないます。
このパターンにおいては、複数の並列単位(スレッド/プロセス)間の通信をすべて
タプルスペースという領域を経由して行います。これによって
プロセス間の通信トポロジーを単純化し、問題を簡単化します。
タプルスペースに対しては、タプルを書き込む(write)、取り出す(take)、
タプルの要素を覗き見る(read)
という操作の...

DRb::DRbServer#thread -> Thread (82207.0)

2.7.0

インスタンスメソッド

サーバのメインスレッドを返します。

サーバのメインスレッドを返します。

このスレッドはクライアントからの接続を受け付けるスレッドであって、
クライアントへの応答をするスレッドではありません。

resolv (78139.0)

2.7.0

ライブラリ

DNSによる名前解決を行うライブラリです。 Ruby で書かれているため thread-aware であり、並列に多くのホスト名を解決することができます。

DNSによる名前解決を行うライブラリです。 Ruby で書かれているため thread-aware であり、並列に多くのホスト名を解決することができます。

DNS モジュールを使うことで、さまざまなリソースを直接ルックアップできます。

なお、単にホスト名から IP アドレスを得たいだけであれば、
socket ライブラリの IPSocket.getaddress などが使用できます。

//emlist[例:][ruby]{
require "resolv"
Resolv.getaddress("www.ruby-lang.org")
Resolv.getname("210.251.121...

Net::IMAP#thread(algorithm, search_keys, charset) -> [Net::IMAP::ThreadMember] (73288.0)

2.7.0

インスタンスメソッド

THREADコマンドを送り、メールボックスを検索した結果をスレッド形式の木構造で返します。

THREADコマンドを送り、メールボックスを検索した結果を
スレッド形式の木構造で返します。

THREAD コマンドは 5256 で定義されています。
詳しくはそちらを参照してください。
このコマンドは Net::IMAP#capability の返り値を見ることで
利用可能かどうか判断できます。

algorithm は木構造を決定するためのアルゴリズムを指定します。
以下の2つが利用可能です。
* "ORDEREDSUBJECT" subjectを使って平坦に区切るだけ
* "REFERENCES" どのメッセージに返事をしているかを見て木構造を作る
詳しくは 5256 を見てく...

絞り込み条件を変える

IRB::Context#thread -> Thread (73225.0)

2.7.0

インスタンスメソッド

現在のスレッドを返します。

現在のスレッドを返します。

@see Thread.current

DRb.#thread -> Thread|nil (73207.0)

2.7.0

モジュール関数

プライマリサーバが動作しているスレッドを返します。

プライマリサーバが動作しているスレッドを返します。

プライマリサーバが存在しない場合は nil を返します。

@see DRb.#primary_server

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

2.7.0

インスタンスメソッド

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

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

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

例:

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

Fiber.new {
Fiber.yield ...

Thread#thread_variable_set(key, value) (72802.0)

2.7.0

インスタンスメソッド

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

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

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

//emlist[例][ruby]{
thr = Thread.new do
Thread.current.thread_variable_set(:cat, 'meow')
Thread.current.thread_variable_set("dog", 'woof')
end
thr.join ...

Thread#thread_variable?(key) -> bool (72748.0)

2.7.0

インスタンスメソッド

引数 key で指定した名前のスレッドローカル変数が存在する場合に true、そうでない場合に false を返します。

引数 key で指定した名前のスレッドローカル変数が存在する場合に true、そ
うでない場合に false を返します。

@param key 変数名を String か Symbol で指定します。

me = Thread.current
me.thread_variable_set(:oliver, "a")
me.thread_variable?(:oliver) # => true
me.thread_variable?(:stanley) # => false

[注意]: Thread#[] でセットしたローカル変数(Fiber ローカル...

絞り込み条件を変える

static void thread_free(rb_thread_t th) (55501.0)

2.7.0

関数

Thread#priority -> Integer (54655.0)

2.7.0

インスタンスメソッド

スレッドの優先度を返します。この値が大きいほど優先度が高くなります。メインスレッドのデフォルト値は 0 です。新しく生成されたスレッドは親スレッドの priority を引き継ぎます。

スレッドの優先度を返します。この値が大きいほど優先度が高くなります。
メインスレッドのデフォルト値は 0 です。新しく生成されたスレッドは親スレッドの
priority を引き継ぎます。

@param val スレッドの優先度を指定します。プラットフォームに依存します。

//emlist[例][ruby]{
Thread.current.priority # => 0

count1 = count2 = 0
a = Thread.new do
loop { count1 += 1 }
end
a.priority = -1

b = Thread.new do
...

Thread#priority=(val) (54655.0)

2.7.0

インスタンスメソッド

Thread.current -> Thread (54640.0)

2.7.0

特異メソッド

現在実行中のスレッド(カレントスレッド)を返します。

現在実行中のスレッド(カレントスレッド)を返します。

p Thread.current #=> #<Thread:0x4022e6fc run>

Thread#report_on_exception -> bool (54463.0)

2.7.0

インスタンスメソッド

真の場合、そのスレッドが例外によって終了した時に、その内容を $stderr に報告します。

真の場合、そのスレッドが例外によって終了した時に、その内容を $stderr に報告します。

デフォルトはスレッド作成時の Thread.report_on_exception です。

@param newstate スレッド実行中に例外発生した場合、その内容を報告するかどうかを true か false で指定します。

//emlist[例][ruby]{
a = Thread.new{ Thread.stop; raise }
a.report_on_exception = true
a.report_on_exception # => true
a.run
# => #<Th...

絞り込み条件を変える

Thread#report_on_exception=(newstate) (54463.0)

2.7.0

インスタンスメソッド

真の場合、そのスレッドが例外によって終了した時に、その内容を $stderr に報告します。

Thread.report_on_exception -> bool (54409.0)

2.7.0

特異メソッド

真の時は、いずれかのスレッドが例外によって終了した時に、その内容を $stderr に報告します。

真の時は、いずれかのスレッドが例外によって終了した時に、その内容を $stderr に報告します。

デフォルトは true です。

Thread.new { 1.times { raise } }

は $stderr に以下のように出力します:

#<Thread:...> terminated with exception (report_on_exception is true):
Traceback (most recent call last):
2: from -e:1:in `block in <main>'
1: fro...

Thread.report_on_exception=(newstate) (54409.0)

2.7.0

特異メソッド

真の時は、いずれかのスレッドが例外によって終了した時に、その内容を $stderr に報告します。

Thread#backtrace_locations(range) -> [Thread::Backtrace::Location] | nil (46345.0)

2.7.0

インスタンスメソッド

スレッドの現在のバックトレースを Thread::Backtrace::Location の配列で返します。

スレッドの現在のバックトレースを Thread::Backtrace::Location の配
列で返します。

引数で指定した値が範囲外の場合、スレッドがすでに終了している場合は nil
を返します。

@param start 開始フレームの位置を数値で指定します。

@param length 取得するフレームの個数を指定します。

@param range 取得したいフレームの範囲を示す Range オブジェクトを指定します。

Kernel.#caller_locations と似ていますが、本メソッドは self に限定
した情報を返します。

//emlist[例][ruby]...

Etc::SC_THREAD_THREADS_MAX -> Integer (46252.0)

2.7.0

定数

Etc.#sysconf の引数に指定します。

Etc.#sysconf の引数に指定します。

詳細は sysconf(3) を参照してください。

絞り込み条件を変える

Thread#backtrace_locations(start = 0, length = nil) -> [Thread::Backtrace::Location] | nil (46045.0)

2.7.0

インスタンスメソッド

スレッドの現在のバックトレースを Thread::Backtrace::Location の配列で返します。

Thread#group -> ThreadGroup (45919.0)

2.7.0

インスタンスメソッド

スレッドが属している ThreadGroup オブジェクトを返します。

スレッドが属している ThreadGroup オブジェクトを返します。

p Thread.current.group == ThreadGroup::Default
# => true

Thread.pending_interrupt?(error = nil) -> bool (45835.0)

2.7.0

特異メソッド

非同期割り込みのキューが空かどうかを返します。

非同期割り込みのキューが空かどうかを返します。

Thread.handle_interrupt は非同期割り込みの発生を延期させるのに使
用しますが、本メソッドは任意の非同期割り込みが存在するかどうかを確認す
るのに使用します。

本メソッドが true を返した場合、Thread.handle_interrupt で例外の
発生を延期するブロックを終了すると延期させられていた例外を発生させるこ
とができます。

@param error 対象の例外クラスを指定します。省略した場合は全ての例外を対
象に確認を行います。

例: 延期させられていた例外をただちに発生...

Thread.fork(*arg) {|*arg| ... } -> Thread (45661.0)

2.7.0

特異メソッド

スレッドを生成して、ブロックの評価を開始します。生成したスレッドを返します。

スレッドを生成して、ブロックの評価を開始します。
生成したスレッドを返します。

基本的に Thread.new と同じですが、
new メソッドと違い initialize メソッドを呼びません。

@param arg 引数 arg はそのままブロックに渡されます。スレッドの開始と同時にその
スレッド固有のローカル変数に値を渡すために使用します。

@raise ThreadError 現在のスレッドが属する ThreadGroup が freeze されている場合に発生します。またブロックを与えられずに呼ばれた場合にも発生します。

注意:

例えば、以下のコー...

Thread.start(*arg) {|*arg| ... } -> Thread (45661.0)

2.7.0

特異メソッド

スレッドを生成して、ブロックの評価を開始します。生成したスレッドを返します。

絞り込み条件を変える

Thread#raise(error_type, message, traceback) -> () (45637.0)

2.7.0

インスタンスメソッド

自身が表すスレッドで強制的に例外を発生させます。

自身が表すスレッドで強制的に例外を発生させます。

@param error_type Kernel.#raise を参照してください。

@param message Kernel.#raise を参照してください。

@param traceback Kernel.#raise を参照してください。

Thread.new {
sleep 1
Thread.main.raise "foobar"
}

begin
sleep
rescue
p $!, $@
end

=> #<RuntimeError: foobar>
[...

Thread#pending_interrupt?(error = nil) -> bool (45619.0)

2.7.0

インスタンスメソッド

self の非同期例外のキューが空かどうかを返します。

self の非同期例外のキューが空かどうかを返します。

@param error 対象の例外クラスを指定します。

@see Thread.pending_interrupt?

Thread.handle_interrupt(hash) { ... } -> object (45571.0)

2.7.0

特異メソッド

スレッドの割り込みのタイミングを引数で指定した内容に変更してブロックを実行します。

スレッドの割り込みのタイミングを引数で指定した内容に変更してブロックを
実行します。

「割り込み」とは、非同期イベントや Thread#raise や
Thread#kill、Signal.#trap(未サポート)、メインスレッドの終了
(メインスレッドが終了すると、他のスレッドも終了されます)を意味します。

@param hash 例外クラスがキー、割り込みのタイミングを指定する
Symbol が値の Hash を指定します。
値の内容は以下のいずれかです。

: :immediate

すぐに割り込みます。

: :on_block...

Thread#abort_on_exception -> bool (45457.0)

2.7.0

インスタンスメソッド

真の場合、そのスレッドが例外によって終了した時に、インタプリタ全体を中断させます。false の場合、あるスレッドで起こった例外は、Thread#join などで検出されない限りそのスレッドだけをなにも警告を出さずに終了させます。

真の場合、そのスレッドが例外によって終了した時に、インタプリタ
全体を中断させます。false の場合、あるスレッドで起こった例
外は、Thread#join などで検出されない限りそのスレッ
ドだけをなにも警告を出さずに終了させます。

デフォルトは偽です。c:Thread#exceptionを参照してください。

@param newstate 自身を実行中に例外発生した場合、インタプリタ全体を終了させるかどうかを true か false で指定します。

//emlist[例][ruby]{
thread = Thread.new { sleep 1 }
thread.abort_o...

Thread#abort_on_exception=(newstate) (45457.0)

2.7.0

インスタンスメソッド

絞り込み条件を変える

Thread#run -> self (45421.0)

2.7.0

インスタンスメソッド

停止状態(stop)のスレッドを再開させます。 Thread#wakeup と異なりすぐにスレッドの切り替えを行います。

停止状態(stop)のスレッドを再開させます。
Thread#wakeup と異なりすぐにスレッドの切り替え
を行います。

@raise ThreadError 死んでいるスレッドに対して実行すると発生します。

//emlist[例][ruby]{
a = Thread.new { puts "a"; Thread.stop; puts "c" }
sleep 0.1 while a.status!='sleep'
puts "Got here"
a.run
a.join
# => a
# => Got here
# => c
//}

@see Thread#wakeup, Threa...

Thread.abort_on_exception -> bool (45421.0)

2.7.0

特異メソッド

真の時は、いずれかのスレッドが例外によって終了した時に、インタプリタ全体を中断させます。false の場合、あるスレッドで起こった例外は、Thread#join などで検出されない限りそのスレッドだけをなにも警告を出さずに終了させます。

真の時は、いずれかのスレッドが例外によって終了した時に、インタプリタ
全体を中断させます。false の場合、あるスレッドで起こった例外は、Thread#join
などで検出されない限りそのスレッドだけをなにも警告を出さずに終了させます。

デフォルトは false です。

c:Thread#exceptionを参照してください。

@param newstate スレッド実行中に例外発生した場合、インタプリタ全体を終了させるかどうかを true か false で指定します。

//emlist[例][ruby]{
Thread.abort_on_exception # => false...

Thread.abort_on_exception=(newstate) (45421.0)

2.7.0

特異メソッド

Thread#set_trace_func(pr) -> Proc | nil (45409.0)

2.7.0

インスタンスメソッド

スレッドにトレース用ハンドラを設定します。

スレッドにトレース用ハンドラを設定します。

nil を渡すとトレースを解除します。

設定したハンドラを返します。

//emlist[例][ruby]{
th = Thread.new do
class Trace
end
2.to_s
Thread.current.set_trace_func nil
3.to_s
end
th.set_trace_func lambda {|*arg| p arg }
th.join

# => ["line", "example.rb", 2, nil, #<Binding:0x00007fc8de87cb08>, nil]
#...

Thread#add_trace_func(pr) -> Proc (45337.0)

2.7.0

インスタンスメソッド

スレッドにトレース用ハンドラを追加します。

スレッドにトレース用ハンドラを追加します。

追加したハンドラを返します。

@param pr トレースハンドラ(Proc オブジェクト)

//emlist[例][ruby]{
th = Thread.new do
class Trace
end
43.to_s
end
th.add_trace_func lambda {|*arg| p arg }
th.join

# => ["line", "example.rb", 4, nil, #<Binding:0x00007f98e107d0d8>, nil]
# => ["c-call", "example.rb", 4, ...

絞り込み条件を変える

<< 1 2 3 ... > >>

別のキーワード

種類

ライブラリ

クラス

モジュール

キーワード

検索結果

先頭5件

thread (132001.0)

static void rb_thread_wait_other_threads(void) (114901.0)

static VALUE rb_thread_raise(int argc, VALUE *argv, rb_thread_t th) (97201.0)

static VALUE rb_thread_start_0(VALUE (*fn)(), void *arg, rb_thread_t th_arg) (97201.0)

static VALUE rb_thread_yield(VALUE arg, rb_thread_t th) (97201.0)

static int rb_thread_dead(rb_thread_t th) (97201.0)

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

static rb_thread_t rb_thread_alloc(VALUE klass) (97201.0)

static rb_thread_t rb_thread_check(VALUE data) (97201.0)

static void rb_thread_ready(rb_thread_t th) (97201.0)

static void rb_thread_remove(rb_thread_t th) (97201.0)

static void rb_thread_restore_context(rb_thread_t th, int exit) (97201.0)

static void rb_thread_save_context(rb_thread_t th) (97201.0)

VALUE rb_thread_run(VALUE thread) (96949.0)

VALUE rb_thread_wakeup(VALUE thread) (96949.0)

VALUE rb_thread_local_aref(VALUE thread, ID id) (96901.0)

VALUE rb_thread_local_aset(VALUE thread, ID id, VALUE val) (96901.0)

static VALUE rb_thread_abort_exc(VALUE thread) (96901.0)

static VALUE rb_thread_abort_exc_set(VALUE thread, VALUE val) (96901.0)

static VALUE rb_thread_alive_p(VALUE thread) (96901.0)

static VALUE rb_thread_aref(VALUE thread, VALUE id) (96901.0)

static VALUE rb_thread_aset(VALUE thread, VALUE id, VALUE val) (96901.0)

static VALUE rb_thread_initialize(VALUE thread, VALUE args) (96901.0)

static VALUE rb_thread_inspect(VALUE thread) (96901.0)

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

static VALUE rb_thread_key_p(VALUE thread, VALUE id) (96901.0)

static VALUE rb_thread_keys(VALUE thread) (96901.0)

static VALUE rb_thread_kill(VALUE thread) (96901.0)

static VALUE rb_thread_priority(VALUE thread) (96901.0)

static VALUE rb_thread_priority_set(VALUE thread, VALUE prio) (96901.0)

static VALUE rb_thread_raise_m(int argc, VALUE *argv, VALUE thread) (96901.0)

static VALUE rb_thread_safe_level(VALUE thread) (96901.0)

static VALUE rb_thread_status(VALUE thread) (96901.0)

static VALUE rb_thread_stop_p(VALUE thread) (96901.0)

static VALUE rb_thread_value(VALUE thread) (96901.0)

VALUE rb_thread_stop(void) (96649.0)

static VALUE rb_thread_pass(void) (96649.0)

void rb_thread_schedule(void) (96637.0)

VALUE rb_thread_create(fn, arg) (96601.0)

VALUE rb_thread_current(void) (96601.0)

VALUE rb_thread_list(void) (96601.0)

VALUE rb_thread_main(void) (96601.0)

int rb_thread_alone(void) (96601.0)

int rb_thread_fd_writable(int fd) (96601.0)

static VALUE rb_thread_critical_get(void) (96601.0)

static VALUE rb_thread_critical_set(VALUE obj, VALUE val) (96601.0)

static VALUE rb_thread_exit(void) (96601.0)

static VALUE rb_thread_s_abort_exc(void) (96601.0)

static VALUE rb_thread_s_abort_exc_set(VALUE self, VALUE val) (96601.0)

static VALUE rb_thread_s_kill(VALUE obj, VALUE th) (96601.0)

static VALUE rb_thread_s_new(int argc, VALUE *argv, VALUE klass) (96601.0)

static VALUE rb_thread_start(VALUE klass, VALUE args) (96601.0)

static void rb_thread_cleanup(void) (96601.0)

static void rb_thread_deadlock(void) (96601.0)

void rb_gc_mark_threads(void) (96601.0)

void rb_thread_atfork(void) (96601.0)

void rb_thread_fd_close(int fd) (96601.0)

void rb_thread_interrupt(void) (96601.0)

void rb_thread_signal_raise(char *sig) (96601.0)

void rb_thread_sleep(int sec) (96601.0)

void rb_thread_sleep_forever(void) (96601.0)

void rb_thread_start_timer(void) (96601.0)

void rb_thread_stop_timer(void) (96601.0)

void rb_thread_trap_eval(VALUE cmd, int sig) (96601.0)

void rb_thread_wait_fd(int fd) (96601.0)

void rb_thread_wait_for(struct timeval time) (96601.0)

rinda/rinda (96091.0)

DRb::DRbServer#thread -> Thread (82207.0)

resolv (78139.0)

Net::IMAP#thread(algorithm, search_keys, charset) -> [Net::IMAP::ThreadMember] (73288.0)

IRB::Context#thread -> Thread (73225.0)

DRb.#thread -> Thread|nil (73207.0)

static VALUE rb_thread_start_0(VALUE (fn)(), void arg, rb_thread_t th_arg) (97201.0)

Thread.fork(arg) {|arg| ... } -> Thread (45661.0)

Thread.start(arg) {|arg| ... } -> Thread (45661.0)