ライブラリ
クラス
- Exception (1)
-
Net
:: IMAP (4) -
Net
:: IMAP :: ThreadMember (2) - PStore (1)
- Thread (39)
-
Thread
:: Backtrace :: Location (7) -
Thread
:: ConditionVariable (4) -
Thread
:: Mutex (6) -
Thread
:: Queue (12) -
Thread
:: SizedQueue (9) - ThreadGroup (5)
- ThreadsWait (6)
- Tracer (3)
- WIN32OLE (1)
-
YAML
:: Store (1)
キーワード
- << (1)
-
CLOCK
_ THREAD _ CPUTIME _ ID (1) -
CP
_ THREAD _ ACP (1) -
CS
_ GNU _ LIBPTHREAD _ VERSION (1) -
CS
_ POSIX _ V7 _ THREADS _ CFLAGS (1) -
CS
_ POSIX _ V7 _ THREADS _ LDFLAGS (1) - ConditionVariable (1)
- DEBUG= (1)
- Default (1)
- Location (1)
-
MUTEX
_ FOR _ THREAD _ EXCLUSIVE (1) -
SC
_ READER _ WRITER _ LOCKS (1) -
SC
_ THREAD _ PRIORITY _ SCHEDULING (1) -
SC
_ XOPEN _ REALTIME _ THREADS (1) - SizedQueue (1)
- [] (1)
- []= (1)
-
abort
_ on _ exception (2) -
absolute
_ path (1) - add (1)
- alive? (1)
-
all
_ waits (3) - backtrace (1)
-
backtrace
_ locations (3) -
base
_ label (1) - broadcast (1)
-
caller
_ locations (2) - children (1)
- clear (1)
-
client
_ thread (1) -
client
_ thread= (1) - close (2)
- closed? (1)
- deq (2)
-
display
_ thread _ id (1) -
display
_ thread _ id= (1) -
display
_ thread _ id? (1) - empty? (3)
- enclose (1)
- enclosed? (1)
- enq (2)
- exclusive (1)
- exit (1)
- fetch (1)
- finished? (1)
-
handle
_ interrupt (1) - inspect (1)
- join (2)
- key? (1)
- keys (1)
- kill (2)
- label (1)
- length (2)
- lineno (1)
- list (2)
- lock (1)
- locked? (1)
- new (3)
-
next
_ wait (1) - owned? (1)
- pass (1)
- path (1)
-
pending
_ interrupt? (2) -
pipeline
_ r (2) -
pipeline
_ rw (2) -
pipeline
_ start (1) -
pipeline
_ w (1) - pop (2)
- priority= (1)
- push (2)
-
rb
_ thread _ abort _ exc (1) -
rb
_ thread _ abort _ exc _ set (1) -
rb
_ thread _ alive _ p (1) -
rb
_ thread _ alloc (1) -
rb
_ thread _ alone (1) -
rb
_ thread _ aref (1) -
rb
_ thread _ aset (1) -
rb
_ thread _ check (1) -
rb
_ thread _ cleanup (1) -
rb
_ thread _ create (1) -
rb
_ thread _ critical _ get (1) -
rb
_ thread _ critical _ set (1) -
rb
_ thread _ current (1) -
rb
_ thread _ deadlock (1) -
rb
_ thread _ exit (1) -
rb
_ thread _ fd _ close (1) -
rb
_ thread _ fd _ writable (1) -
rb
_ thread _ initialize (1) -
rb
_ thread _ inspect (1) -
rb
_ thread _ join (1) -
rb
_ thread _ join _ m (1) -
rb
_ thread _ key _ p (1) -
rb
_ thread _ keys (1) -
rb
_ thread _ kill (1) -
rb
_ thread _ list (1) -
rb
_ thread _ local _ aref (1) -
rb
_ thread _ local _ aset (1) -
rb
_ thread _ main (1) -
rb
_ thread _ pass (1) -
rb
_ thread _ priority (1) -
rb
_ thread _ priority _ set (1) -
rb
_ thread _ raise (1) -
rb
_ thread _ raise _ m (1) -
rb
_ thread _ run (1) -
rb
_ thread _ s _ abort _ exc (1) -
rb
_ thread _ s _ abort _ exc _ set (1) -
rb
_ thread _ s _ kill (1) -
rb
_ thread _ s _ new (1) -
rb
_ thread _ safe _ level (1) -
rb
_ thread _ schedule (1) -
rb
_ thread _ signal _ raise (1) -
rb
_ thread _ sleep (1) -
rb
_ thread _ sleep _ forever (1) -
rb
_ thread _ start (1) -
rb
_ thread _ start _ 0 (1) -
rb
_ thread _ status (1) -
rb
_ thread _ stop (1) -
rb
_ thread _ stop _ p (1) -
rb
_ thread _ trap _ eval (1) -
rb
_ thread _ value (1) -
rb
_ thread _ wait _ for (1) -
rb
_ thread _ wakeup (1) -
rb
_ thread _ yield (1) -
report
_ on _ exception (2) - run (1)
-
safe
_ level (1) - seqno (1)
-
set
_ trace _ func (1) - shift (2)
- signal (1)
- size (2)
- sleep (1)
- status (1)
- stop (1)
- stop? (1)
-
sync
_ ex _ locker (1) -
sync
_ ex _ locker= (1) - terminate (1)
-
thgroup
_ add (1) -
thread
_ keys _ i (1) -
thread
_ variable? (1) -
thread
_ variable _ get (1) -
thread
_ variable _ set (1) -
to
_ s (1) -
try
_ lock (1) -
uid
_ thread (1) - unlock (1)
- value (1)
- wait (1)
- wakeup (1)
検索結果
先頭5件
-
Thread
# thread _ variable _ get(key) -> object | nil (118456.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) (118402.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 (118348.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 ローカル... -
Thread
:: MUTEX _ FOR _ THREAD _ EXCLUSIVE -> Mutex (118252.0) -
Thread.exclusive用のMutexオブジェクトです。 (private constant です。)
Thread.exclusive用のMutexオブジェクトです。
(private constant です。) -
Net
:: IMAP # thread(algorithm , search _ keys , charset) -> [Net :: IMAP :: ThreadMember] (92188.0) -
THREADコマンドを送り、メールボックスを検索した結果を スレッド形式の木構造で返します。
THREADコマンドを送り、メールボックスを検索した結果を
スレッド形式の木構造で返します。
THREAD コマンドは 5256 で定義されています。
詳しくはそちらを参照してください。
このコマンドは Net::IMAP#capability の返り値を見ることで
利用可能かどうか判断できます。
algorithm は木構造を決定するためのアルゴリズムを指定します。
以下の2つが利用可能です。
* "ORDEREDSUBJECT" subjectを使って平坦に区切るだけ
* "REFERENCES" どのメッセージに返事をしているかを見て木構造を作る
詳しくは 5256 を見てく... -
DRb
. # thread -> Thread|nil (92107.0) -
プライマリサーバが動作しているスレッドを返します。
プライマリサーバが動作しているスレッドを返します。
プライマリサーバが存在しない場合は nil を返します。
@see DRb.#primary_server -
VALUE rb
_ thread _ local _ aset(VALUE thread , ID id , VALUE val) (74401.0) -
-
static VALUE rb
_ thread _ initialize(VALUE thread , VALUE args) (74401.0) -
-
static VALUE rb
_ thread _ value(VALUE thread) (74401.0) -
-
static VALUE rb
_ thread _ yield(VALUE arg , rb _ thread _ t th) (74401.0) -
-
Thread
# backtrace _ locations(range) -> [Thread :: Backtrace :: Location] | nil (74245.0) -
スレッドの現在のバックトレースを Thread::Backtrace::Location の配 列で返します。
スレッドの現在のバックトレースを Thread::Backtrace::Location の配
列で返します。
引数で指定した値が範囲外の場合、スレッドがすでに終了している場合は nil
を返します。
@param start 開始フレームの位置を数値で指定します。
@param length 取得するフレームの個数を指定します。
@param range 取得したいフレームの範囲を示す Range オブジェクトを指定します。
Kernel.#caller_locations と似ていますが、本メソッドは self に限定
した情報を返します。
//emlist[例][ruby]... -
Net
:: IMAP # client _ thread -> Thread (74107.0) -
このメソッドは obsolete です。使わないでください。
このメソッドは obsolete です。使わないでください。 -
VALUE rb
_ thread _ local _ aref(VALUE thread , ID id) (74101.0) -
-
static VALUE rb
_ thread _ alive _ p(VALUE thread) (74101.0) -
-
static VALUE rb
_ thread _ kill(VALUE thread) (74101.0) -
-
static VALUE rb
_ thread _ safe _ level(VALUE thread) (74101.0) -
-
static rb
_ thread _ t rb _ thread _ alloc(VALUE klass) (74101.0) -
-
Thread
# backtrace _ locations(start = 0 , length = nil) -> [Thread :: Backtrace :: Location] | nil (73945.0) -
スレッドの現在のバックトレースを Thread::Backtrace::Location の配 列で返します。
スレッドの現在のバックトレースを Thread::Backtrace::Location の配
列で返します。
引数で指定した値が範囲外の場合、スレッドがすでに終了している場合は nil
を返します。
@param start 開始フレームの位置を数値で指定します。
@param length 取得するフレームの個数を指定します。
@param range 取得したいフレームの範囲を示す Range オブジェクトを指定します。
Kernel.#caller_locations と似ていますが、本メソッドは self に限定
した情報を返します。
//emlist[例][ruby]... -
static VALUE rb
_ thread _ critical _ set(VALUE obj , VALUE val) (73801.0) -
-
static VALUE rb
_ thread _ s _ kill(VALUE obj , VALUE th) (73801.0) -
-
Tracer
. display _ thread _ id=(flag) (73504.0) -
スレッド ID を表示するかどうかを設定します。
スレッド ID を表示するかどうかを設定します。
@param flag スレッド ID を表示するならば、真を指定します。 -
void rb
_ thread _ schedule(void) (73237.0) -
他のスレッドに実行権を渡します。 対象の特定はできません。
他のスレッドに実行権を渡します。
対象の特定はできません。
@see rb_thread_wait_fd, rb_thread_wait_for -
Tracer
. display _ thread _ id -> bool (73207.0) -
真ならば、スレッド ID を表示します。 デフォルトは、真です。
真ならば、スレッド ID を表示します。
デフォルトは、真です。 -
Tracer
. display _ thread _ id? -> bool (73207.0) -
真ならば、スレッド ID を表示します。 デフォルトは、真です。
真ならば、スレッド ID を表示します。
デフォルトは、真です。 -
Net
:: IMAP # client _ thread=(th) (73204.0) -
このメソッドは obsolete です。使わないでください。
このメソッドは obsolete です。使わないでください。 -
Process
:: CLOCK _ THREAD _ CPUTIME _ ID -> Integer (73204.0) -
Process.#clock_gettime で使われます。
Process.#clock_gettime で使われます。
システムによっては定義されていません。 -
VALUE rb
_ thread _ list(void) (73201.0) -
-
int rb
_ thread _ alone(void) (73201.0) -
評価器にスレッドが一つしか存在しないとき真。
評価器にスレッドが一つしか存在しないとき真。 -
int rb
_ thread _ fd _ writable(int fd) (73201.0) -
-
static VALUE rb
_ thread _ critical _ get(void) (73201.0) -
-
static void rb
_ thread _ cleanup(void) (73201.0) -
-
static void rb
_ thread _ deadlock(void) (73201.0) -
-
void rb
_ thread _ fd _ close(int fd) (73201.0) -
-
void rb
_ thread _ signal _ raise(char *sig) (73201.0) -
-
void rb
_ thread _ sleep(int sec) (73201.0) -
-
void rb
_ thread _ sleep _ forever(void) (73201.0) -
-
void rb
_ thread _ trap _ eval(VALUE cmd , int sig) (73201.0) -
-
Thread
. handle _ interrupt(hash) { . . . } -> object (72871.0) -
スレッドの割り込みのタイミングを引数で指定した内容に変更してブロックを 実行します。
スレッドの割り込みのタイミングを引数で指定した内容に変更してブロックを
実行します。
「割り込み」とは、非同期イベントや Thread#raise や
Thread#kill、Signal.#trap(未サポート)、メインスレッドの終了
(メインスレッドが終了すると、他のスレッドも終了されます)を意味します。
@param hash 例外クラスがキー、割り込みのタイミングを指定する
Symbol が値の Hash を指定します。
値の内容は以下のいずれかです。
: :immediate
すぐに割り込みます。
: :on_block... -
Thread
. kill(thread) -> Thread (65293.0) -
指定したスレッド thread に対して Thread#exit を呼びます。終了したスレッドを返します。
指定したスレッド thread に対して Thread#exit を呼びます。終了したスレッドを返します。
@param thread 終了したい Thread オブジェクトを指定します。
th = Thread.new do
end
p Thread.kill(th) #=> #<Thread:0x40221bc8 dead> -
Net
:: IMAP :: ThreadMember # children -> [Net :: IMAP :: ThreadMember] (64501.0) -
スレッドの木構造における自身の下位の部分を返します。
スレッドの木構造における自身の下位の部分を返します。 -
Thread
. list -> [Thread] (64276.0) -
全ての生きているスレッドを含む配列を生成して返します。aborting 状態であるスレッド も要素に含まれます。
全ての生きているスレッドを含む配列を生成して返します。aborting 状態であるスレッド
も要素に含まれます。
Thread.new do
sleep
end
sleep 0.1
p Thread.list #=> [#<Thread:0x40377a54 sleep>, #<Thread:0x4022e6fc run>] -
Thread
# priority=(val) (63955.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
... -
WIN32OLE
:: CP _ THREAD _ ACP -> Integer (63904.0) -
現在実行中のスレッドの既定のコードページ(3)を示します。
現在実行中のスレッドの既定のコードページ(3)を示します。
Windowsのコードページはスレッド毎に異なる値を設定できます。 -
Thread
# report _ on _ exception -> bool (63763.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 -> bool (63709.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
# safe _ level -> Integer (63637.0) -
self のセーフレベルを返します。カレントスレッドの safe_level は、$SAFE と同じです。
self のセーフレベルを返します。カレントスレッドの
safe_level は、$SAFE と同じです。
Ruby 2.6 から$SAFEがプロセスグローバルになったため、このメソッドは obsolete になりました。
セーフレベルについてはspec/safelevelを参照してください。
//emlist[例][ruby]{
thr = Thread.new { $SAFE = 1; sleep }
Thread.current.safe_level # => 0
thr.safe_level # => 1
//} -
Thread
# value -> object (63421.0) -
スレッド self が終了するまで待ち(Thread#join と同じ)、 そのスレッドのブロックが返した値を返します。スレッド実行中に例外が 発生した場合には、その例外を再発生させます。
スレッド self が終了するまで待ち(Thread#join と同じ)、
そのスレッドのブロックが返した値を返します。スレッド実行中に例外が
発生した場合には、その例外を再発生させます。
スレッドが Thread#kill によって終了した場合は、返り値は不定です。
以下は、生成したすべてのスレッドの終了を待ち結果を出力する例です。
threads = []
threads.push(Thread.new { n = rand(5); sleep n; n })
threads.push(Thread.new { n = rand(5); sleep n; n })... -
Thread
# alive? -> bool (63409.0) -
スレッドが「生きている」時、true を返します。
スレッドが「生きている」時、true を返します。
例:
thr = Thread.new { }
thr.join # => #<Thread:0x401b3fb0 dead>
Thread.current.alive? # => true
thr.alive? # => false
Thread#status が真を返すなら、このメソッドも真です。
@see Thread#status, Thread#stop? -
Thread
. exclusive { . . . } -> object (63391.0) -
VM グローバルの Mutex をロックし、ブロックを実行します。
VM グローバルの Mutex をロックし、ブロックを実行します。
このクラスメソッドの挙動は 1.8 以前とは違います。
Thread.exclusive は VM グローバルの Thread::MUTEX_FOR_THREAD_EXCLUSIVE の
synchronize を呼び出しているだけで、Thread.exclusive していないスレッドは動きます。
Thread::Mutex や Monitor などの他の排他制御の方法を検討してください。 -
static VALUE rb
_ thread _ aset(VALUE thread , VALUE id , VALUE val) (56701.0) -
-
static VALUE rb
_ thread _ abort _ exc _ set(VALUE thread , VALUE val) (56401.0) -
-
static VALUE rb
_ thread _ aref(VALUE thread , VALUE id) (56401.0) -
-
static VALUE rb
_ thread _ join _ m(int argc , VALUE *argv , VALUE thread) (56401.0) -
-
static VALUE rb
_ thread _ key _ p(VALUE thread , VALUE id) (56401.0) -
-
static VALUE rb
_ thread _ priority _ set(VALUE thread , VALUE prio) (56401.0) -
-
static VALUE rb
_ thread _ raise(int argc , VALUE *argv , rb _ thread _ t th) (56401.0) -
-
static VALUE rb
_ thread _ raise _ m(int argc , VALUE *argv , VALUE thread) (56401.0) -
-
static VALUE rb
_ thread _ start _ 0(VALUE (*fn)() , void *arg , rb _ thread _ t th _ arg) (56401.0) -
-
Net
:: IMAP # uid _ thread(algorithm , search _ keys , charset) -> [Net :: IMAP :: ThreadMember] (56188.0) -
THREADコマンドを送り、メールボックスを検索した結果を スレッド形式の木構造で返します。
THREADコマンドを送り、メールボックスを検索した結果を
スレッド形式の木構造で返します。
ほぼ Net::IMAP#thread と同じですが、返ってくるオブジェクトの
Net::IMAP::ThreadMember#seqno の内容が message sequence number
ではなく UID となります。
@param algorithm スレッド構造構築アルゴリズム名(文字列)
@param search_key 検索条件(文字列配列)
@param charset 検索条件の解釈に用いるCHARSET名(文字列)
@see Net::IMAP::ThreadMember... -
VALUE rb
_ thread _ run(VALUE thread) (56149.0) -
スレッド thread に実行権を渡します。
スレッド thread に実行権を渡します。 -
VALUE rb
_ thread _ wakeup(VALUE thread) (56149.0) -
停止中のスレッド thread を再開させます。
停止中のスレッド thread を再開させます。 -
static VALUE rb
_ thread _ abort _ exc(VALUE thread) (56101.0) -
-
static VALUE rb
_ thread _ inspect(VALUE thread) (56101.0) -
-
static VALUE rb
_ thread _ keys(VALUE thread) (56101.0) -
-
static VALUE rb
_ thread _ priority(VALUE thread) (56101.0) -
-
static VALUE rb
_ thread _ status(VALUE thread) (56101.0) -
-
static VALUE rb
_ thread _ stop _ p(VALUE thread) (56101.0) -
-
static int rb
_ thread _ join(rb _ thread _ t th , double limit) (56101.0) -
-
static rb
_ thread _ t rb _ thread _ check(VALUE data) (56101.0) -
-
static VALUE rb
_ thread _ s _ abort _ exc _ set(VALUE self , VALUE val) (55801.0) -
-
static VALUE rb
_ thread _ s _ new(int argc , VALUE *argv , VALUE klass) (55801.0) -
-
static VALUE rb
_ thread _ start(VALUE klass , VALUE args) (55801.0) -
-
static int thread
_ keys _ i(ID key , VALUE value , VALUE ary) (55801.0) -
-
Etc
:: SC _ XOPEN _ REALTIME _ THREADS -> Integer (55552.0) -
Etc.#sysconf の引数に指定します。
Etc.#sysconf の引数に指定します。
詳細は sysconf(3) を参照してください。 -
VALUE rb
_ thread _ stop(void) (55249.0) -
現在実行中のスレッドを停止します。 他のスレッドから rb_thread_wakeup を呼ばれると再開します。
現在実行中のスレッドを停止します。
他のスレッドから rb_thread_wakeup を呼ばれると再開します。 -
static VALUE rb
_ thread _ pass(void) (55249.0) -
Thread#pass の実体。
Thread#pass の実体。 -
Etc
:: CS _ GNU _ LIBPTHREAD _ VERSION -> Integer (55201.0) -
Etc.#confstr の引数に指定します。
Etc.#confstr の引数に指定します。
詳細は confstr(3) を参照してください。 -
Etc
:: CS _ POSIX _ V7 _ THREADS _ CFLAGS -> Integer (55201.0) -
Etc.#confstr の引数に指定します。
Etc.#confstr の引数に指定します。
詳細は confstr(3) を参照してください。 -
Etc
:: CS _ POSIX _ V7 _ THREADS _ LDFLAGS -> Integer (55201.0) -
Etc.#confstr の引数に指定します。
Etc.#confstr の引数に指定します。
詳細は confstr(3) を参照してください。 -
VALUE rb
_ thread _ create(fn , arg) (55201.0) -
VALUE (*fn)(); void *arg;
VALUE (*fn)();
void *arg; -
VALUE rb
_ thread _ current(void) (55201.0) -
現在実行中のスレッドを返します。
現在実行中のスレッドを返します。 -
VALUE rb
_ thread _ main(void) (55201.0) -
メインスレッド (プロセスの一番最初に存在するスレッド) を返します。
メインスレッド (プロセスの一番最初に存在するスレッド) を返します。 -
static VALUE rb
_ thread _ exit(void) (55201.0) -
-
static VALUE rb
_ thread _ s _ abort _ exc(void) (55201.0) -
-
void rb
_ thread _ wait _ for(struct timeval time) (55201.0) -
time の長さの時間が経過するまでカレントスレッドを停止します。
time の長さの時間が経過するまでカレントスレッドを停止します。 -
Thread
. pending _ interrupt?(error = nil) -> bool (55135.0) -
非同期割り込みのキューが空かどうかを返します。
非同期割り込みのキューが空かどうかを返します。
Thread.handle_interrupt は非同期割り込みの発生を延期させるのに使
用しますが、本メソッドは任意の非同期割り込みが存在するかどうかを確認す
るのに使用します。
本メソッドが true を返した場合、Thread.handle_interrupt で例外の
発生を延期するブロックを終了すると延期させられていた例外を発生させるこ
とができます。
@param error 対象の例外クラスを指定します。省略した場合は全ての例外を対
象に確認を行います。
例: 延期させられていた例外をただちに発生... -
Thread
# pending _ interrupt?(error = nil) -> bool (54919.0) -
self の非同期例外のキューが空かどうかを返します。
self の非同期例外のキューが空かどうかを返します。
@param error 対象の例外クラスを指定します。
@see Thread.pending_interrupt? -
Thread
# abort _ on _ exception -> bool (54757.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
# run -> self (54721.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 (54721.0) -
真の時は、いずれかのスレッドが例外によって終了した時に、インタプリタ 全体を中断させます。false の場合、あるスレッドで起こった例外は、Thread#join などで検出されない限りそのスレッドだけをなにも警告を出さずに終了させます。
真の時は、いずれかのスレッドが例外によって終了した時に、インタプリタ
全体を中断させます。false の場合、あるスレッドで起こった例外は、Thread#join
などで検出されない限りそのスレッドだけをなにも警告を出さずに終了させます。
デフォルトは false です。
c:Thread#exceptionを参照してください。
@param newstate スレッド実行中に例外発生した場合、インタプリタ全体を終了させるかどうかを true か false で指定します。
//emlist[例][ruby]{
Thread.abort_on_exception # => false... -
Thread
# set _ trace _ func(pr) -> Proc | nil (54709.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
# backtrace -> [String] | nil (54637.0) -
スレッドの現在のバックトレースを返します。
スレッドの現在のバックトレースを返します。
スレッドがすでに終了している場合は nil を返します。
//emlist[例][ruby]{
class C1
def m1
sleep 5
end
def m2
m1
end
end
th = Thread.new {C1.new.m2; Thread.stop}
th.backtrace
# => [
# [0] "(irb):3:in `sleep'",
# [1] "(irb):3:in `m1'",
# [2] "(irb):6:in `m2'",
# [3] ... -
Thread
# terminate -> self (54637.0) -
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
ただし、スレッドは終了処理中(aborting)にはなりますが、
直ちに終了するとは限りません。すでに終了している場合は何もしません。このメソッドにより
終了したスレッドの Thread#value の返り値は不定です。
自身がメインスレッドであるか最後のスレッドである場合は、プロセスを Kernel.#exit(0)
により終了します。
Kernel.#exit と違い例外 SystemExit を発生しません。
th1 = Thread.new do
begin
sleep 10
... -
Thread
:: Queue # clear -> () (54637.0) -
キューを空にします。返り値は不定です。
キューを空にします。返り値は不定です。
//emlist[例][ruby]{
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.length # => 4
q.clear
q.length # => 0
//} -
Thread
:: Mutex # try _ lock -> bool (54601.0) -
mutex をロックしようとして、ロックが成功した場合、真を返します。 ロックできなかった場合にはブロックせず偽を返します。
mutex をロックしようとして、ロックが成功した場合、真を返します。
ロックできなかった場合にはブロックせず偽を返します。
//emlist[例][ruby]{
m = Mutex.new
m.try_lock # => true
m.try_lock # => false
//} -
Thread
# kill -> self (54337.0) -
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
ただし、スレッドは終了処理中(aborting)にはなりますが、
直ちに終了するとは限りません。すでに終了している場合は何もしません。このメソッドにより
終了したスレッドの Thread#value の返り値は不定です。
自身がメインスレッドであるか最後のスレッドである場合は、プロセスを Kernel.#exit(0)
により終了します。
Kernel.#exit と違い例外 SystemExit を発生しません。
th1 = Thread.new do
begin
sleep 10
... -
Thread
:: ConditionVariable (54163.0) -
スレッドの同期機構の一つである状態変数を実現するクラスです。
スレッドの同期機構の一つである状態変数を実現するクラスです。
以下も ConditionVariable を理解するのに参考になります。
https://ruby-doc.com/docs/ProgrammingRuby/html/tut_threads.html#UF
=== Condition Variable とは
あるスレッド A が排他領域で動いていたとします。スレッド A は現在空いていない
リソースが必要になったので空くまで待つことにしたとします。これはうまくいきません。
なぜなら、スレッド A は排他領域で動いているわけですから、他のスレッドは動くことが
できません。リ... -
ThreadsWait
. all _ waits(*threads) {|thread| . . . } -> () (47320.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.inspect) }
# 出力例
#=... -
ThreadsWait
. all _ waits(*threads) -> () (46420.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.inspect) }
# 出力例
#=... -
Etc
:: SC _ THREAD _ PRIORITY _ SCHEDULING -> Integer (46252.0) -
Etc.#sysconf の引数に指定します。
Etc.#sysconf の引数に指定します。
詳細は sysconf(3) を参照してください。