種類
ライブラリ
- English (4)
- ビルトイン (235)
-
cgi
/ core (1) - csv (37)
- dbm (1)
- drb (2)
- erb (4)
- etc (21)
- fileutils (1)
- gdbm (1)
-
io
/ console (1) -
io
/ wait (3) -
irb
/ context (3) -
irb
/ input-method (9) - json (5)
-
net
/ ftp (5) -
net
/ http (19) -
net
/ imap (9) -
net
/ pop (2) -
net
/ protocol (1) -
net
/ smtp (3) - open-uri (8)
- open3 (10)
- openssl (17)
- pathname (8)
- pstore (2)
- pty (4)
-
rdoc
/ markup (1) - readline (42)
-
rinda
/ rinda (2) -
rinda
/ tuplespace (2) -
rubygems
/ package / tar _ header (1) -
rubygems
/ package / tar _ reader (7) -
rubygems
/ package / tar _ reader / entry (13) -
rubygems
/ source _ info _ cache (2) -
rubygems
/ specification (1) - shell (4)
-
shell
/ command-processor (4) -
shell
/ filter (4) - socket (14)
- stringio (20)
- sync (4)
- tempfile (3)
- thwait (13)
- timeout (2)
- tracer (4)
-
webrick
/ httpproxy (3) -
webrick
/ server (1) -
win32
/ registry (23) - win32ole (2)
-
yaml
/ store (1) - zlib (35)
クラス
-
ARGF
. class (18) - Addrinfo (2)
- CSV (27)
-
CSV
:: Row (2) -
CSV
:: Table (7) - DBM (1)
-
DRb
:: DRbServer (1) - Dir (10)
- ERB (3)
-
Encoding
:: Converter (1) -
Encoding
:: InvalidByteSequenceError (1) - Exception (1)
- File (9)
-
File
:: Stat (4) - GDBM (1)
-
Gem
:: Package :: TarHeader (1) -
Gem
:: Package :: TarReader (5) -
Gem
:: Package :: TarReader :: Entry (12) -
Gem
:: SourceInfoCache (2) -
Gem
:: Specification (1) - IO (63)
-
IRB
:: Context (3) -
IRB
:: InputMethod (1) -
IRB
:: ReadlineInputMethod (6) -
IRB
:: StdioInputMethod (1) -
JSON
:: Parser (3) - Module (1)
-
Net
:: FTP (4) -
Net
:: FTP :: MLSxEntry (1) -
Net
:: HTTP (12) -
Net
:: HTTPGenericRequest (2) -
Net
:: HTTPResponse (5) -
Net
:: IMAP (5) -
Net
:: IMAP :: ContentDisposition (1) -
Net
:: IMAP :: ThreadMember (2) -
Net
:: POP3 (2) -
Net
:: SMTP (3) -
OpenSSL
:: PKCS7 (2) -
OpenSSL
:: SSL :: SSLSocket (1) - PStore (2)
- Pathname (7)
-
Rinda
:: TupleSpace (2) -
Rinda
:: TupleSpaceProxy (2) - Shell (4)
-
Shell
:: CommandProcessor (4) -
Shell
:: Filter (4) - Socket (6)
- String (1)
- StringIO (19)
- Tempfile (3)
- Thread (56)
-
Thread
:: Backtrace :: Location (7) -
Thread
:: ConditionVariable (4) -
Thread
:: Mutex (8) -
Thread
:: Queue (14) -
Thread
:: SizedQueue (10) - ThreadGroup (6)
- ThreadsWait (10)
- Tracer (4)
- UNIXServer (4)
-
WEBrick
:: GenericServer (1) - WIN32OLE (2)
-
Win32
:: Registry (11) -
YAML
:: Store (1) -
Zlib
:: GzipReader (27) -
Zlib
:: GzipWriter (7)
モジュール
-
CGI
:: QueryExtension (1) - DRb (1)
- Etc (21)
- FileTest (3)
- FileUtils (1)
- JSON (2)
- Kernel (15)
- Open3 (10)
-
OpenSSL
:: ASN1 (1) -
OpenSSL
:: Buffering (6) -
OpenSSL
:: Random (1) - OpenURI (2)
-
OpenURI
:: OpenRead (3) - PTY (4)
- Process (2)
- Readline (26)
-
Socket
:: Constants (2) -
Sync
_ m (4) - Timeout (2)
-
Win32
:: Registry :: Constants (12)
オブジェクト
-
Readline
:: HISTORY (14) -
WEBrick
:: NullReader (2)
キーワード
-
$ DEFAULT _ OUTPUT (1) -
$ INPUT _ LINE _ NUMBER (1) -
$ LAST _ READ _ LINE (1) -
$ NR (1) -
1
. 6 . 8から1 . 8 . 0への変更点(まとめ) (1) - << (5)
- Buffering (1)
-
CLOCK
_ THREAD _ CPUTIME _ ID (1) -
CP
_ THREAD _ ACP (1) - CSV (1)
-
CS
_ GNU _ LIBPTHREAD _ VERSION (1) -
CS
_ POSIX _ V7 _ THREADS _ CFLAGS (1) -
CS
_ POSIX _ V7 _ THREADS _ LDFLAGS (1) - ConditionVariable (1)
- DEBUG (1)
- DEBUG= (1)
- Default (1)
- Digest (1)
- EALREADY (1)
- ERB (1)
- Entry (1)
- ErrNoFinishedThread (1)
- ErrNoWaitingThread (1)
- ExtensionFactory (1)
-
FILENAME
_ COMPLETION _ PROC (1) - GzipReader (1)
- HISTORY (1)
- IO (1)
-
Init
_ Thread (1) -
KEY
_ ALL _ ACCESS (1) -
KEY
_ CREATE _ LINK (1) -
KEY
_ CREATE _ SUB _ KEY (1) -
KEY
_ ENUMERATE _ SUB _ KEYS (1) -
KEY
_ EXECUTE (1) -
KEY
_ NOTIFY (1) -
KEY
_ QUERY _ VALUE (1) -
KEY
_ READ (1) -
KEY
_ SET _ VALUE (1) -
KEY
_ WRITE (1) - Location (1)
-
MSG
_ HAVEMORE (2) -
MUTEX
_ FOR _ THREAD _ EXCLUSIVE (1) - Markup (1)
- Mutex (1)
-
NEWS for Ruby 2
. 1 . 0 (1) -
NEWS for Ruby 2
. 2 . 0 (1) -
NEWS for Ruby 2
. 3 . 0 (1) - NullReader (1)
- OpenRead (1)
- Pathname (1)
- Queue (1)
- READER (2)
- RSA (1)
- ReadTimeout (1)
- Readline (1)
- ReadlineInputMethod (1)
- Request (1)
-
SC
_ READER _ WRITER _ LOCKS (1) -
SC
_ THREADS (1) -
SC
_ THREAD _ ATTR _ STACKADDR (1) -
SC
_ THREAD _ ATTR _ STACKSIZE (1) -
SC
_ THREAD _ CPUTIME (1) -
SC
_ THREAD _ DESTRUCTOR _ ITERATIONS (1) -
SC
_ THREAD _ KEYS _ MAX (1) -
SC
_ THREAD _ PRIORITY _ SCHEDULING (1) -
SC
_ THREAD _ PRIO _ INHERIT (1) -
SC
_ THREAD _ PRIO _ PROTECT (1) -
SC
_ THREAD _ PROCESS _ SHARED (1) -
SC
_ THREAD _ ROBUST _ PRIO _ INHERIT (1) -
SC
_ THREAD _ ROBUST _ PRIO _ PROTECT (1) -
SC
_ THREAD _ SAFE _ FUNCTIONS (1) -
SC
_ THREAD _ SPORADIC _ SERVER (1) -
SC
_ THREAD _ STACK _ MIN (1) -
SC
_ THREAD _ THREADS _ MAX (1) -
SC
_ XOPEN _ REALTIME _ THREADS (1) -
SO
_ NREAD (2) - SSLServer (1)
-
STANDARD
_ RIGHTS _ READ (1) -
STANDARD
_ RIGHTS _ WRITE (1) - SizedQueue (1)
- StringIO (1)
- TarReader (1)
- Thread (1)
- ThreadError (1)
- ThreadGroup (1)
- ThreadMember (1)
- ThreadsWait (1)
-
USERNAME
_ COMPLETION _ PROC (1) - UnexpectedEOF (1)
- VERSION (1)
- WaitReadable (1)
- [] (2)
- []= (2)
-
abort
_ on _ exception (2) -
abort
_ on _ exception= (2) -
absolute
_ path (1) - add (1)
-
add
_ row (1) -
add
_ trace _ func (1) - alive? (1)
-
all
_ waits (3) -
attr
_ reader (1) - backtrace (1)
-
backtrace
_ locations (3) -
base
_ label (1) -
basic
_ quote _ characters (1) -
basic
_ quote _ characters= (1) -
basic
_ word _ break _ characters (1) -
basic
_ word _ break _ characters= (1) - binmode (1)
- binread (2)
- birthtime (1)
- body (1)
-
body
_ stream (1) -
body
_ stream= (1) - broadcast (1)
-
bytes
_ read (1) -
caller
_ locations (2) - cgi (1)
- children (1)
- clear (2)
-
client
_ thread (1) -
client
_ thread= (1) - clone (1)
- close (5)
-
close
_ read (3) -
close
_ write (1) - closed? (4)
-
closed
_ read? (1) -
completer
_ quote _ characters (1) -
completer
_ quote _ characters= (1) -
completer
_ word _ break _ characters (1) -
completer
_ word _ break _ characters= (1) -
completion
_ append _ character (1) -
completion
_ append _ character= (1) -
completion
_ case _ fold (1) -
completion
_ case _ fold= (1) -
completion
_ proc (1) -
completion
_ proc= (1) - connect (1)
-
connect
_ from (2) -
connect
_ nonblock (1) - convert (3)
-
copy
_ stream (3) - count (1)
- current (1)
- decode (1)
-
def
_ class (1) -
delete
_ at (1) - deq (2)
- detach (1)
- directory? (1)
-
display
_ thread _ id (1) -
display
_ thread _ id= (1) -
display
_ thread _ id? (1) - dup (1)
- each (5)
-
each
_ byte (2) -
each
_ entry (1) -
each
_ line (2) -
emacs
_ editing _ mode (1) - empty? (4)
- enclose (1)
- enclosed? (1)
- encoding (1)
- enq (2)
- entity (1)
- eof (1)
- eof? (3)
- exclusive (1)
- exit (2)
- expunge (1)
- fdatasync (1)
-
field
_ size _ limit (1) - fields (1)
- file (1)
- file? (1)
- filename (2)
- filename= (1)
-
filename
_ quote _ characters (1) -
filename
_ quote _ characters= (1) - finished? (1)
- flock (1)
- flush (2)
- fork (1)
- from (1)
-
full
_ name (1) - get2 (2)
-
get
_ screen _ size (1) -
get
_ thread _ no (1) - getc (3)
- getpty (2)
- gets (4)
- group (1)
-
handle
_ interrupt (1) - header (1)
-
header
_ converters (1) - headers (1)
- input= (1)
- inspect (3)
- instance (2)
- join (3)
-
join
_ nowait (1) - key? (1)
- keys (1)
- kill (2)
- label (1)
- length (3)
- line (1)
- lineno (2)
- lineno= (1)
- link (1)
- list (2)
- load (1)
-
load
_ random _ file (1) - lock (1)
- locked? (1)
- main (1)
- max (1)
- max= (1)
- multipart? (1)
- name (1)
- name= (1)
- new (22)
-
next
_ wait (1) - nread (1)
-
num
_ waiting (1) -
ole
_ get _ methods (1) - open (23)
- open-uri (1)
-
open
_ timeout (2) -
open
_ timeout= (2) -
open
_ uri (2) - output= (1)
- owned? (1)
- param (1)
- parse (1)
- pass (1)
- path (2)
-
pending
_ interrupt? (2) - pipe (8)
-
pipeline
_ r (2) -
pipeline
_ rw (2) -
pipeline
_ start (1) -
pipeline
_ w (1) - pop (3)
- popen (14)
- popen2 (1)
- popen2e (1)
- popen3 (2)
- pos (2)
- pos= (1)
- post2 (2)
-
primitive
_ errinfo (1) - print (1)
- printf (1)
- priority (1)
- priority= (1)
- push (4)
- putc (1)
- puts (2)
- raise (1)
- raw (1)
-
rb
_ attr (1) -
rb
_ define _ attr (1) -
rb
_ define _ readonly _ variable (1) -
rb
_ gc _ mark _ threads (1) -
rb
_ mod _ attr _ reader (1) -
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 _ atfork (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 _ dead (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 _ interrupt (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 _ ready (1) -
rb
_ thread _ remove (1) -
rb
_ thread _ restore _ context (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 _ save _ context (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 _ start _ timer (1) -
rb
_ thread _ status (1) -
rb
_ thread _ stop (1) -
rb
_ thread _ stop _ p (1) -
rb
_ thread _ stop _ timer (1) -
rb
_ thread _ trap _ eval (1) -
rb
_ thread _ value (1) -
rb
_ thread _ wait _ fd (1) -
rb
_ thread _ wait _ for (1) -
rb
_ thread _ wait _ other _ threads (1) -
rb
_ thread _ wakeup (1) -
rb
_ thread _ yield (1) -
rdoc
/ parser / c (1) -
read
_ all (2) -
read
_ all _ cache _ data (1) -
read
_ bin (1) -
read
_ body (2) -
read
_ cache _ data (1) -
read
_ escape (1) -
read
_ i (1) -
read
_ nonblock (4) -
read
_ only (1) -
read
_ s (1) -
read
_ smime (1) -
read
_ timeout (4) -
read
_ timeout= (4) - readable? (8)
-
readable
_ atfer _ eof? (3) -
readable
_ real? (7) -
readagain
_ bytes (1) - readbyte (3)
- readchar (5)
-
reader
_ header (1) - readline (13)
- readlines (16)
- readlink (5)
-
readonly
_ setter (1) - readpartial (7)
- ready (1)
- ready? (1)
- reopen (2)
-
report
_ on _ exception (2) -
report
_ on _ exception= (2) -
request
_ get (2) -
request
_ post (2) - restore (1)
- rewind (4)
-
rinda
/ rinda (1) -
row
_ sep (1) - rss (1)
-
ruby 1
. 6 feature (1) -
ruby 1
. 8 . 2 feature (1) -
ruby 1
. 8 . 3 feature (1) -
ruby 1
. 8 . 4 feature (1) -
ruby 1
. 8 . 5 feature (1) -
ruby 1
. 9 feature (1) -
rubygems
/ package / tar _ reader (1) -
rubygems
/ package / tar _ reader / entry (1) - run (1)
-
safe
_ level (1) - seek (1)
- select (2)
- seqno (1)
-
set
_ screen _ size (1) -
set
_ trace _ func (1) - shift (4)
- signal (1)
- size (3)
-
skip
_ blanks? (1) - sleep (1)
- source (1)
- spawn (6)
-
stack
_ extend (1) - start (1)
- status (1)
- stop (1)
- stop? (1)
-
sync
_ ex _ locker (1) -
sync
_ ex _ locker= (1) -
sync
_ upgrade _ waiting (1) -
sync
_ waiting (1) - synchronize (1)
- sysread (5)
- sysseek (1)
- syswrite (1)
- table (1)
- tcp (2)
- tell (1)
- terminate (1)
-
thgroup
_ add (1) - thread (5)
-
thread
_ free (1) -
thread
_ keys _ i (1) -
thread
_ mark (1) -
thread
_ status _ name (1) -
thread
_ switch (1) -
thread
_ variable? (1) -
thread
_ variable _ get (1) -
thread
_ variable _ set (1) - threads (1)
- timeout (2)
-
to
_ a (3) -
to
_ csv (1) -
to
_ s (3) - tokens (1)
- transaction (1)
-
try
_ lock (1) -
uid
_ thread (1) - ungetc (2)
- unlock (1)
- unused (1)
-
use
_ readline (1) -
use
_ readline? (1) - value (1)
-
values
_ at (1) -
vi
_ editing _ mode (1) - wait (1)
-
wait
_ readable (1) - wakeup (1)
-
win32
/ registry (1) -
world
_ readable? (7) - wrap (2)
- write (5)
-
write
_ smime (1) - スレッド (1)
検索結果
先頭5件
-
Thread
# key?(name) -> bool (9001.0) -
name に対応したスレッドに固有のデータが定義されていれば true を返します。
name に対応したスレッドに固有のデータが定義されていれば
true を返します。
@param name 文字列か Symbol で指定します。
//emlist[例][ruby]{
me = Thread.current
me[:oliver] = "a"
me.key?(:oliver) # => true
me.key?(:stanley) # => false
//} -
Thread
# keys -> [Symbol] (9001.0) -
スレッド固有データに関連づけられたキーの配列を返します。キーは Symbol で返されます。
スレッド固有データに関連づけられたキーの配列を返します。キーは
Symbol で返されます。
th = Thread.current
th[:foo] = 'FOO'
th['bar'] = 'BAR'
p th.keys
#=> [:bar, :foo] -
Thread
# kill -> self (9001.0) -
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
ただし、スレッドは終了処理中(aborting)にはなりますが、
直ちに終了するとは限りません。すでに終了している場合は何もしません。このメソッドにより
終了したスレッドの Thread#value の返り値は不定です。
自身がメインスレッドであるか最後のスレッドである場合は、プロセスを Kernel.#exit(0)
により終了します。
Kernel.#exit と違い例外 SystemExit を発生しません。
th1 = Thread.new do
begin
sleep 10
... -
Thread
# name -> String (9001.0) -
self の名前を返します。
self の名前を返します。
@see Thread#name= -
Thread
# name=(name) -> String (9001.0) -
self の名前を name に設定します。
self の名前を name に設定します。
プラットフォームによっては pthread やカーネルにも設定を行う場合があります。
@raise ArgumentError 引数に ASCII 互換ではないエンコーディングのものを
指定した場合に発生します。
//emlist[例][ruby]{
a = Thread.new{}
a.name = 'named'
a.name # => "named"
a.inspect # => "#<Thread:0x00007f85ac8721f0@named@(irb):1 dead>"
... -
Thread
# pending _ interrupt?(error = nil) -> bool (9001.0) -
self の非同期例外のキューが空かどうかを返します。
self の非同期例外のキューが空かどうかを返します。
@param error 対象の例外クラスを指定します。
@see Thread.pending_interrupt? -
Thread
# priority -> Integer (9001.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) (9001.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
# raise(error _ type , message , traceback) -> () (9001.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
# report _ on _ exception -> bool (9001.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) (9001.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
# run -> self (9001.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
# safe _ level -> Integer (9001.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
# set _ trace _ func(pr) -> Proc | nil (9001.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
# status -> String | false | nil (9001.0) -
生きているスレッドの状態を文字列 "run"、"sleep", "aborting" のいず れかで返します。正常終了したスレッドに対して false、例外によ り終了したスレッドに対して nil を返します。
生きているスレッドの状態を文字列 "run"、"sleep", "aborting" のいず
れかで返します。正常終了したスレッドに対して false、例外によ
り終了したスレッドに対して nil を返します。
Thread#alive? が真を返すなら、このメソッドも真です。
例:
a = Thread.new { raise("die now") }
b = Thread.new { Thread.stop }
c = Thread.new { Thread.exit }
d = Thread.new { sleep }
d.kill ... -
Thread
# stop? -> bool (9001.0) -
スレッドが終了(dead)あるいは停止(stop)している時、true を返します。
スレッドが終了(dead)あるいは停止(stop)している時、true を返します。
//emlist[例][ruby]{
a = Thread.new { Thread.stop }
b = Thread.current
a.stop? # => true
b.stop? # => false
//}
@see Thread#alive?, Thread#status -
Thread
# terminate -> self (9001.0) -
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
スレッドの実行を終了させます。終了時に ensure 節が実行されます。
ただし、スレッドは終了処理中(aborting)にはなりますが、
直ちに終了するとは限りません。すでに終了している場合は何もしません。このメソッドにより
終了したスレッドの Thread#value の返り値は不定です。
自身がメインスレッドであるか最後のスレッドである場合は、プロセスを Kernel.#exit(0)
により終了します。
Kernel.#exit と違い例外 SystemExit を発生しません。
th1 = Thread.new do
begin
sleep 10
... -
Thread
# value -> object (9001.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
# wakeup -> self (9001.0) -
停止状態(stop)のスレッドを実行可能状態(run)にします。
停止状態(stop)のスレッドを実行可能状態(run)にします。
@raise ThreadError 死んでいるスレッドに対して実行すると発生します。
//emlist[例][ruby]{
c = Thread.new { Thread.stop; puts "hey!" }
sleep 0.1 while c.status!='sleep'
c.wakeup
c.join
# => "hey!"
//}
@see Thread#run, Thread.stop -
Thread
. DEBUG -> Integer (9001.0) -
スレッドのデバッグレベルを返します。
スレッドのデバッグレベルを返します。
スレッドのデバッグレベルが 0 のときはなにもしません。
それ以外の場合は、スレッドのデバッグログを標準出力に出力します。
初期値は 0 です。
使用するためには、THREAD_DEBUG を -1 にして Ruby をコンパイルする必要が
あります。
//emlist[例][ruby]{
Thread.DEBUG # => 0
//}
@see Thread.DEBUG= -
Thread
. DEBUG=(val) (9001.0) -
スレッドのデバッグレベルを val に設定します。
スレッドのデバッグレベルを val に設定します。
val が 真 のときは Integer に変換してから設定します。
偽 のときは 0 を設定します。
使用するためには、THREAD_DEBUG を -1 にして Ruby をコンパイルする必要が
あります。
//emlist[例][ruby]{
Thread.DEBUG # => 0
Thread.DEBUG = 1
Thread.DEBUG # => 1
//}
@see Thread.DEBUG -
Thread
. abort _ on _ exception -> bool (9001.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) (9001.0) -
真の時は、いずれかのスレッドが例外によって終了した時に、インタプリタ 全体を中断させます。false の場合、あるスレッドで起こった例外は、Thread#join などで検出されない限りそのスレッドだけをなにも警告を出さずに終了させます。
真の時は、いずれかのスレッドが例外によって終了した時に、インタプリタ
全体を中断させます。false の場合、あるスレッドで起こった例外は、Thread#join
などで検出されない限りそのスレッドだけをなにも警告を出さずに終了させます。
デフォルトは false です。
c:Thread#exceptionを参照してください。
@param newstate スレッド実行中に例外発生した場合、インタプリタ全体を終了させるかどうかを true か false で指定します。
//emlist[例][ruby]{
Thread.abort_on_exception # => false... -
Thread
. exclusive { . . . } -> object (9001.0) -
VM グローバルの Mutex をロックし、ブロックを実行します。
VM グローバルの Mutex をロックし、ブロックを実行します。
このクラスメソッドの挙動は 1.8 以前とは違います。
Thread.exclusive は VM グローバルの Thread::MUTEX_FOR_THREAD_EXCLUSIVE の
synchronize を呼び出しているだけで、Thread.exclusive していないスレッドは動きます。
Thread::Mutex や Monitor などの他の排他制御の方法を検討してください。 -
Thread
. exit -> () (9001.0) -
カレントスレッドに対して Thread#exit を呼びます。
カレントスレッドに対して Thread#exit を呼びます。 -
Thread
. handle _ interrupt(hash) { . . . } -> object (9001.0) -
スレッドの割り込みのタイミングを引数で指定した内容に変更してブロックを 実行します。
スレッドの割り込みのタイミングを引数で指定した内容に変更してブロックを
実行します。
「割り込み」とは、非同期イベントや Thread#raise や
Thread#kill、Signal.#trap(未サポート)、メインスレッドの終了
(メインスレッドが終了すると、他のスレッドも終了されます)を意味します。
@param hash 例外クラスがキー、割り込みのタイミングを指定する
Symbol が値の Hash を指定します。
値の内容は以下のいずれかです。
: :immediate
すぐに割り込みます。
: :on_block... -
Thread
. pass -> nil (9001.0) -
他のスレッドに実行権を譲ります。実行中のスレッドの状態を変えずに、 他の実行可能状態のスレッドに制御を移します。
他のスレッドに実行権を譲ります。実行中のスレッドの状態を変えずに、
他の実行可能状態のスレッドに制御を移します。
Thread.new do
(1..3).each{|i|
p i
Thread.pass
}
exit
end
loop do
Thread.pass
p :main
end
#=>
1
:main
2
:main
3
:main -
Thread
. pending _ interrupt?(error = nil) -> bool (9001.0) -
非同期割り込みのキューが空かどうかを返します。
非同期割り込みのキューが空かどうかを返します。
Thread.handle_interrupt は非同期割り込みの発生を延期させるのに使
用しますが、本メソッドは任意の非同期割り込みが存在するかどうかを確認す
るのに使用します。
本メソッドが true を返した場合、Thread.handle_interrupt で例外の
発生を延期するブロックを終了すると延期させられていた例外を発生させるこ
とができます。
@param error 対象の例外クラスを指定します。省略した場合は全ての例外を対
象に確認を行います。
例: 延期させられていた例外をただちに発生... -
Thread
. report _ on _ exception -> bool (9001.0) -
真の時は、いずれかのスレッドが例外によって終了した時に、その内容を $stderr に報告します。
真の時は、いずれかのスレッドが例外によって終了した時に、その内容を $stderr に報告します。
デフォルトは false です。
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: fr... -
Thread
. report _ on _ exception=(newstate) (9001.0) -
真の時は、いずれかのスレッドが例外によって終了した時に、その内容を $stderr に報告します。
真の時は、いずれかのスレッドが例外によって終了した時に、その内容を $stderr に報告します。
デフォルトは false です。
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: fr... -
Thread
. stop -> nil (9001.0) -
他のスレッドから Thread#run メソッドで再起動されるまで、カレ ントスレッドの実行を停止します。
他のスレッドから Thread#run メソッドで再起動されるまで、カレ
ントスレッドの実行を停止します。
//emlist[例][ruby]{
a = Thread.new { print "a"; Thread.stop; print "c" }
sleep 0.1 while a.status!='sleep'
print "b"
a.run
a.join
# => "abc"
//}
@see Thread#run, Thread#wakeup -
Thread
:: Backtrace :: Location (9001.0) -
Ruby のフレームを表すクラスです。
Ruby のフレームを表すクラスです。
Kernel.#caller_locations から生成されます。
//emlist[例1][ruby]{
# caller_locations.rb
def a(skip)
caller_locations(skip)
end
def b(skip)
a(skip)
end
def c(skip)
b(skip)
end
c(0..2).map do |call|
puts call.to_s
end
//}
例1の実行結果:
caller_locations.rb:2:in `a'
caller_locations... -
Thread
:: Backtrace :: Location # absolute _ path -> String (9001.0) -
self が表すフレームの絶対パスを返します。
self が表すフレームの絶対パスを返します。
//emlist[例][ruby]{
# foo.rb
class Foo
attr_accessor :locations
def initialize(skip)
@locations = caller_locations(skip)
end
end
Foo.new(0..2).locations.map do |call|
puts call.absolute_path
end
# => /path/to/foo.rb
# /path/to/foo.rb
# /path/to/foo.rb
//}
@see... -
Thread
:: Backtrace :: Location # base _ label -> String (9001.0) -
self が表すフレームの基本ラベルを返します。通常、 Thread::Backtrace::Location#label から修飾を取り除いたもので構成 されます。
self が表すフレームの基本ラベルを返します。通常、
Thread::Backtrace::Location#label から修飾を取り除いたもので構成
されます。
//emlist[例][ruby]{
# foo.rb
class Foo
attr_accessor :locations
def initialize(skip)
@locations = caller_locations(skip)
end
end
Foo.new(0..2).locations.map do |call|
puts call.base_label
end
# => init... -
Thread
:: Backtrace :: Location # inspect -> String (9001.0) -
Thread::Backtrace::Location#to_s の結果を人間が読みやすいような文 字列に変換したオブジェクトを返します。
Thread::Backtrace::Location#to_s の結果を人間が読みやすいような文
字列に変換したオブジェクトを返します。
//emlist[例][ruby]{
# foo.rb
class Foo
attr_accessor :locations
def initialize(skip)
@locations = caller_locations(skip)
end
end
Foo.new(0..2).locations.map do |call|
puts call.inspect
end
# => "path/to/foo.rb:5:in ... -
Thread
:: Backtrace :: Location # label -> String (9001.0) -
self が表すフレームのラベルを返します。通常、メソッド名、クラス名、モ ジュール名などで構成されます。
self が表すフレームのラベルを返します。通常、メソッド名、クラス名、モ
ジュール名などで構成されます。
例: Thread::Backtrace::Location の例1を用いた例
//emlist[][ruby]{
loc = c(0..1).first
loc.label # => "a"
//}
@see Thread::Backtrace::Location#base_label -
Thread
:: Backtrace :: Location # lineno -> Integer (9001.0) -
self が表すフレームの行番号を返します。
self が表すフレームの行番号を返します。
例: Thread::Backtrace::Location の例1を用いた例
//emlist[][ruby]{
loc = c(0..1).first
loc.lineno # => 2
//} -
Thread
:: Backtrace :: Location # path -> String (9001.0) -
self が表すフレームのファイル名を返します。
self が表すフレームのファイル名を返します。
例: Thread::Backtrace::Location の例1を用いた例
//emlist[][ruby]{
loc = c(0..1).first
loc.path # => "caller_locations.rb"
//}
@see Thread::Backtrace::Location#absolute_path -
Thread
:: Backtrace :: Location # to _ s -> String (9001.0) -
self が表すフレームを Kernel.#caller と同じ表現にした文字列を返し ます。
self が表すフレームを Kernel.#caller と同じ表現にした文字列を返し
ます。
//emlist[例][ruby]{
# foo.rb
class Foo
attr_accessor :locations
def initialize(skip)
@locations = caller_locations(skip)
end
end
Foo.new(0..2).locations.map do |call|
puts call.to_s
end
# => path/to/foo.rb:5:in `initialize'
# path/to/foo... -
Thread
:: ConditionVariable (9001.0) -
スレッドの同期機構の一つである状態変数を実現するクラスです。
スレッドの同期機構の一つである状態変数を実現するクラスです。
以下も ConditionVariable を理解するのに参考になります。
https://ruby-doc.com/docs/ProgrammingRuby/html/tut_threads.html#UF
=== Condition Variable とは
あるスレッド A が排他領域で動いていたとします。スレッド A は現在空いていない
リソースが必要になったので空くまで待つことにしたとします。これはうまくいきません。
なぜなら、スレッド A は排他領域で動いているわけですから、他のスレッドは動くことが
できません。リ... -
Thread
:: ConditionVariable # broadcast -> self (9001.0) -
状態変数を待っているスレッドをすべて再開します。再開された スレッドは Thread::ConditionVariable#wait で指定した mutex のロックを試みます。
状態変数を待っているスレッドをすべて再開します。再開された
スレッドは Thread::ConditionVariable#wait
で指定した mutex のロックを試みます。
@return 常に self を返します。
//emlist[例][ruby]{
mutex = Mutex.new
cv = ConditionVariable.new
flg = true
3.times {
Thread.start {
mutex.synchronize {
puts "a1"
while (flg)
cv.wait(mutex)
... -
Thread
:: ConditionVariable # signal -> self (9001.0) -
状態変数を待っているスレッドを1つ再開します。再開された スレッドは Thread::ConditionVariable#wait で指定した mutex のロックを試みます。
状態変数を待っているスレッドを1つ再開します。再開された
スレッドは Thread::ConditionVariable#wait
で指定した mutex のロックを試みます。
@return 常に self を返します。
//emlist[例][ruby]{
mutex = Mutex.new
cv = ConditionVariable.new
flg = true
3.times {
Thread.start {
mutex.synchronize {
puts "a1"
while (flg)
cv.wait(mutex)
... -
Thread
:: ConditionVariable # wait(mutex , timeout = nil) -> self (9001.0) -
mutex のロックを解放し、カレントスレッドを停止します。 Thread::ConditionVariable#signalまたは、 Thread::ConditionVariable#broadcastで送られたシグナルを 受け取ると、mutexのロックを取得し、実行状態となります。
mutex のロックを解放し、カレントスレッドを停止します。
Thread::ConditionVariable#signalまたは、
Thread::ConditionVariable#broadcastで送られたシグナルを
受け取ると、mutexのロックを取得し、実行状態となります。
@param mutex Mutex オブジェクトを指定します。
@param timeout スリープする秒数を指定します。この場合はシグナルを受け取
らなかった場合でも指定した秒数が経過するとスリープを終了
します。省略するとスリープし続け... -
Thread
:: Mutex (9001.0) -
Mutex(Mutal Exclusion = 相互排他ロック)は共有データを並行アクセスから保護する ためにあります。Mutex の典型的な使い方は(m を Mutex オブジェクトとします):
Mutex(Mutal Exclusion = 相互排他ロック)は共有データを並行アクセスから保護する
ためにあります。Mutex の典型的な使い方は(m を Mutex オブジェクトとします):
m.lock
begin
# m によって保護されたクリティカルセクション
ensure
m.unlock
end
または、より簡単に
m.synchronize {
# m によって保護されたクリティカルセクション
} -
Thread
:: Mutex # lock -> self (9001.0) -
mutex オブジェクトをロックします。一度に一つのス レッドだけが mutex をロックできます。既にロックされている mutex に対してロックを行おうとしたスレッドは mutex のロックが解放さ れるまで、実行が停止されます。
mutex オブジェクトをロックします。一度に一つのス
レッドだけが mutex をロックできます。既にロックされている mutex
に対してロックを行おうとしたスレッドは mutex のロックが解放さ
れるまで、実行が停止されます。
@raise ThreadError self 既にカレントスレッドにロックされている場合に発
生します。
また、Signal.#trap に指定したハンドラ内で実行
した場合に発生します。
@see Thread::Mutex#unlock
... -
Thread
:: Mutex # locked? -> bool (9001.0) -
mutex がロックされている時、真を返します。
mutex がロックされている時、真を返します。
//emlist[例][ruby]{
m = Mutex.new
m.locked? # => false
m.lock
m.locked? # => true
//} -
Thread
:: Mutex # owned? -> bool (9001.0) -
self がカレントスレッドによってロックされている場合に true を返します。 そうでない場合に false を返します。
self がカレントスレッドによってロックされている場合に true を返します。
そうでない場合に false を返します。
//emlist[例][ruby]{
m = Mutex.new
m.owned? # => false
m.lock
Thread.new do
m.owned? # => false
end.join
m.owned? # => true
//} -
Thread
:: Mutex # sleep(timeout = nil) -> Integer (9001.0) -
与えられた秒数の間ロックを解除してスリープして、実行後にまたロックします。
与えられた秒数の間ロックを解除してスリープして、実行後にまたロックします。
@param timeout スリープする秒数を指定します。省略するとスリープし続けます。
@return スリープしていた秒数を返します。
@raise ThreadError 自身がカレントスレッドによってロックされていない場合に発生します。
[注意] 2.0 以降ではスリープ中でも、シグナルを受信した場合などに実行が再
開(spurious wakeup)される場合がある点に注意してください。
//emlist[例][ruby]{
m = Mutex.new
th = Thread.new do
... -
Thread
:: Mutex # synchronize { . . . } -> object (9001.0) -
mutex をロックし、ブロックを実行します。実行後に必ず mutex のロックを解放します。
mutex をロックし、ブロックを実行します。実行後に必ず mutex のロックを解放します。
ブロックが最後に評価した値を返します。
@raise ThreadError self 既にカレントスレッドにロックされている場合に発
生します。
また、Signal.#trap に指定したハンドラ内で実行
した場合に発生します。
//emlist[例][ruby]{
m = Mutex.new
result = m.synchronize do
m.locked? # =>... -
Thread
:: Mutex # try _ lock -> bool (9001.0) -
mutex をロックしようとして、ロックが成功した場合、真を返します。 ロックできなかった場合にはブロックせず偽を返します。
mutex をロックしようとして、ロックが成功した場合、真を返します。
ロックできなかった場合にはブロックせず偽を返します。
//emlist[例][ruby]{
m = Mutex.new
m.try_lock # => true
m.try_lock # => false
//} -
Thread
:: Mutex # unlock -> self (9001.0) -
mutex のロックを解放します。mutex のロック待ちになっていたスレッドの実行は再開されます。
mutex のロックを解放します。mutex のロック待ちになっていたスレッドの実行は再開されます。
@return self を返します。
例:
m = Mutex.new
begin
m.lock
# critical part
ensure
m.unlock
end
Mutex はロックしたスレッド以外からロックを開放することは出来ません。
ロックしたスレッド以外から unlock が呼ばれると ThreadError が発生します。
m = Mutex.new
m.lock
Thread.new do
m.unlock # => Thr... -
Thread
:: Queue (9001.0) -
Queue はスレッド間の FIFO(first in first out) の通信路です。ス レッドが空のキューを読み出そうとすると停止します。キューになんら かの情報が書き込まれると実行は再開されます。
Queue はスレッド間の FIFO(first in first out) の通信路です。ス
レッドが空のキューを読み出そうとすると停止します。キューになんら
かの情報が書き込まれると実行は再開されます。
最大サイズが指定できる Queue のサブクラス Thread::SizedQueue も提供されています。
=== 例
require 'thread'
q = Queue.new
th1 = Thread.start do
while resource = q.pop
puts resource
end
end
[:resou... -
Thread
:: Queue # <<(value) -> () (9001.0) -
キューの値を追加します。待っているスレッドがいれば実行を再開 させます。返り値は不定です。
キューの値を追加します。待っているスレッドがいれば実行を再開
させます。返り値は不定です。 -
Thread
:: Queue # clear -> () (9001.0) -
キューを空にします。返り値は不定です。
キューを空にします。返り値は不定です。
//emlist[例][ruby]{
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.length # => 4
q.clear
q.length # => 0
//} -
Thread
:: Queue # close -> self (9001.0) -
キューを close します。close 済みのキューを再度 open することはできません。
キューを close します。close 済みのキューを再度 open することはできません。
close 後は以下のように動作します。
* Thread::Queue#closed? は true を返します
* Thread::Queue#close は無視されます
* Thread::Queue#enq/push/<< は ClosedQueueError を発生します
* Thread::Queue#empty? が false を返す場合は Thread::Queue#deq/pop/shift は通常通りオブジェクトを返します
また、ClosedQueueError... -
Thread
:: Queue # closed? -> bool (9001.0) -
キューが close されている時に true を返します。
キューが close されている時に true を返します。
//emlist[例][ruby]{
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.closed? # => false
q.close
q.closed? # => true
//} -
Thread
:: Queue # deq(non _ block = false) -> object (9001.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
@param non_block true を与えると、キューが空の時に例外 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)
}
t... -
Thread
:: Queue # empty? -> bool (9001.0) -
キューが空の時、真を返します。
キューが空の時、真を返します。
//emlist[例][ruby]{
q = Queue.new
q.empty? # => true
q.push(:resource)
q.empty? # => false
//} -
Thread
:: Queue # enq(value) -> () (9001.0) -
キューの値を追加します。待っているスレッドがいれば実行を再開 させます。返り値は不定です。
キューの値を追加します。待っているスレッドがいれば実行を再開
させます。返り値は不定です。 -
Thread
:: Queue # length -> Integer (9001.0) -
キューの長さを返します。
キューの長さを返します。
//emlist[例][ruby]{
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.length # => 4
//} -
Thread
:: Queue # num _ waiting -> Integer (9001.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
//} -
Thread
:: Queue # pop(non _ block = false) -> object (9001.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
@param non_block true を与えると、キューが空の時に例外 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)
}
t... -
Thread
:: Queue # push(value) -> () (9001.0) -
キューの値を追加します。待っているスレッドがいれば実行を再開 させます。返り値は不定です。
キューの値を追加します。待っているスレッドがいれば実行を再開
させます。返り値は不定です。 -
Thread
:: Queue # shift(non _ block = false) -> object (9001.0) -
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。
@param non_block true を与えると、キューが空の時に例外 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)
}
t... -
Thread
:: Queue # size -> Integer (9001.0) -
キューの長さを返します。
キューの長さを返します。
//emlist[例][ruby]{
q = Queue.new
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.length # => 4
//} -
Thread
:: SizedQueue (9001.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
... -
Thread
:: SizedQueue # <<(obj) -> () (9001.0) -
キューに与えられたオブジェクトを追加します。
キューに与えられたオブジェクトを追加します。
キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与えられたオブジェクトを追加します。
@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。
@see Thread::Queue#push -
Thread
:: SizedQueue # close -> self (9001.0) -
キューを close します。詳しくは Thread::Queue#close を参照してください。
キューを close します。詳しくは Thread::Queue#close を参照してください。
Thread::Queue とはキューにオブジェクトを追加するスレッドの動作が
異なります。キューにオブジェクトを追加するスレッドを待機している場合は
ClosedQueueError が発生して中断されます。
//emlist[例][ruby]{
q = SizedQueue.new(4)
[:resource1, :resource2, :resource3, nil].each { |r| q.push(r) }
q.closed? # => false
q.close
q.c... -
Thread
:: SizedQueue # deq(non _ block = false) -> object (9001.0) -
キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。
キューからひとつ値を取り出します。
キューに push しようと待っているスレッドがあれば、実行を再開させます。
@param non_block true を与えると、キューが空の時に例外 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].eac... -
Thread
:: SizedQueue # enq(obj , non _ block = false) -> () (9001.0) -
キューに与えられたオブジェクトを追加します。
キューに与えられたオブジェクトを追加します。
キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与えられたオブジェクトを追加します。
@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。
@see Thread::Queue#push -
Thread
:: SizedQueue # max -> Integer (9001.0) -
キューの最大サイズを返します。
キューの最大サイズを返します。
//emlist[例][ruby]{
q = SizedQueue.new(4)
q.max # => 4
//} -
Thread
:: SizedQueue # max=(n) (9001.0) -
キューの最大サイズを設定します。
キューの最大サイズを設定します。
@param n キューの最大サイズを指定します。
//emlist[例][ruby]{
q = SizedQueue.new(4)
q.max # => 4
q.max = 5
q.max # => 5
//} -
Thread
:: SizedQueue # pop(non _ block = false) -> object (9001.0) -
キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。
キューからひとつ値を取り出します。
キューに push しようと待っているスレッドがあれば、実行を再開させます。
@param non_block true を与えると、キューが空の時に例外 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].eac... -
Thread
:: SizedQueue # push(obj , non _ block = false) -> () (9001.0) -
キューに与えられたオブジェクトを追加します。
キューに与えられたオブジェクトを追加します。
キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与えられたオブジェクトを追加します。
@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。
@see Thread::Queue#push -
Thread
:: SizedQueue # shift(non _ block = false) -> object (9001.0) -
キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。
キューからひとつ値を取り出します。
キューに push しようと待っているスレッドがあれば、実行を再開させます。
@param non_block true を与えると、キューが空の時に例外 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].eac... -
ThreadGroup
# enclose -> self (9001.0) -
自身への ThreadGroup#add によるスレッドの追加・削除を禁止します。 enclose された ThreadGroup に追加や削除を行うと例外 ThreadError が発生します。
自身への ThreadGroup#add によるスレッドの追加・削除を禁止します。
enclose された ThreadGroup に追加や削除を行うと例外 ThreadError が発生します。
ただし、Thread.new によるスレッドの追加は禁止されません。enclose されたスレッドグループ A に
属するスレッドが新たにスレッドを生成した場合、生成されたスレッドはスレッドグループ A に属します。
追加の例:
thg = ThreadGroup.new.enclose
thg.add Thread.new {}
=> -:2:in `add': can't ... -
ThreadGroup
# enclosed? -> bool (9001.0) -
自身が enclose されているなら true を返します。そうでないなら false を返します。デフォルトは false です。
自身が enclose されているなら true を返します。そうでないなら false を返します。デフォルトは false です。
freeze された ThreadGroup には Thread の追加/削除ができませんが、enclosed? は false を返します。
thg = ThreadGroup.new
p thg.enclosed? # => false
thg.enclose
p thg.enclosed? # => true
thg = ThreadGroup.new
p thg.e... -
ThreadsWait
# all _ waits -> () (9001.0) -
指定されたスレッドすべてが終了するまで待ちます。 ブロックが与えられた場合、スレッド終了時にブロックを評価します。
指定されたスレッドすべてが終了するまで待ちます。
ブロックが与えられた場合、スレッド終了時にブロックを評価します。
使用例
require 'thwait'
threads = []
5.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
thall = ThreadsWait.new(*threads)
thall.all_waits{|th|
printf("end %s\n", th.inspect)
}
# 出力例
#=> #<Thread... -
ThreadsWait
# empty? -> bool (9001.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 -
ThreadsWait
# finished? -> bool (9001.0) -
すでに終了したスレッドが存在すれば true を返します。
すでに終了したスレッドが存在すれば true を返します。
使用例
require 'thwait'
threads = []
3.times {|i|
threads << Thread.new { sleep 1; p Thread.current }
}
thall = ThreadsWait.new(*threads)
p thall.finished? #=> false
sleep 3
p thall.finished? #=> true -
Zlib
:: GzipReader # eof -> bool (9001.0) -
圧縮データの終端に達した場合真を返します。 フッターが読み込まれていなくても真を返すことに注意して下さい。
圧縮データの終端に達した場合真を返します。
フッターが読み込まれていなくても真を返すことに注意して下さい。
require 'zlib'
=begin
# hoge.gz がない場合はこれで作成する。
Zlib::GzipWriter.open('hoge.gz') { |gz|
gz.puts 'hoge'
gz.puts 'fuga'
gz.puts 'foga'
}
=end
Zlib::GzipReader.open('hoge.gz'){|gz|
gz.each_line{|line|
puts line... -
Zlib
:: GzipReader # eof? -> bool (9001.0) -
圧縮データの終端に達した場合真を返します。 フッターが読み込まれていなくても真を返すことに注意して下さい。
圧縮データの終端に達した場合真を返します。
フッターが読み込まれていなくても真を返すことに注意して下さい。
require 'zlib'
=begin
# hoge.gz がない場合はこれで作成する。
Zlib::GzipWriter.open('hoge.gz') { |gz|
gz.puts 'hoge'
gz.puts 'fuga'
gz.puts 'foga'
}
=end
Zlib::GzipReader.open('hoge.gz'){|gz|
gz.each_line{|line|
puts line... -
Zlib
:: GzipReader # pos -> Integer (9001.0) -
現在までに展開したデータの長さの合計を返します。 ファイルポインタの位置ではないことに注意して下さい。
現在までに展開したデータの長さの合計を返します。
ファイルポインタの位置ではないことに注意して下さい。
require 'zlib'
Zlib::GzipWriter.open('hoge.gz') { |gz|
gz.puts 'hoge'
}
Zlib::GzipReader.open('hoge.gz'){|gz|
while c = gz.getc
printf "%c, %d\n", c, gz.pos
end
}
# 実行例
#=> h, 1
#=> o, 2
#=> g, 3
#=> e, 4
... -
Zlib
:: GzipReader # rewind -> 0 (9001.0) -
ファイルポインタを Zlib::GzipReader.new を呼び出した直後の 時点に戻します。関連付けられている IO オブジェクトに seek メソッドが定義されている必要があります。
ファイルポインタを Zlib::GzipReader.new を呼び出した直後の
時点に戻します。関連付けられている IO オブジェクトに
seek メソッドが定義されている必要があります。
require 'zlib'
=begin
# hoge.gz がない場合はこれで作成する。
Zlib::GzipWriter.open('hoge.gz') { |gz|
gz.puts 'hoge'
gz.puts 'fuga'
}
=end
gz = Zlib::GzipReader.open('hoge.gz')
puts gz.gets #... -
Zlib
:: GzipReader # tell -> Integer (9001.0) -
現在までに展開したデータの長さの合計を返します。 ファイルポインタの位置ではないことに注意して下さい。
現在までに展開したデータの長さの合計を返します。
ファイルポインタの位置ではないことに注意して下さい。
require 'zlib'
Zlib::GzipWriter.open('hoge.gz') { |gz|
gz.puts 'hoge'
}
Zlib::GzipReader.open('hoge.gz'){|gz|
while c = gz.getc
printf "%c, %d\n", c, gz.pos
end
}
# 実行例
#=> h, 1
#=> o, 2
#=> g, 3
#=> e, 4
... -
Zlib
:: GzipReader # unused -> String | nil (9001.0) -
gzip フォーマットの解析のために読み込んだ余剰のデータを返します。 gzip ファイルが最後まで解析されていない場合は nil を返します。
gzip フォーマットの解析のために読み込んだ余剰のデータを返します。
gzip ファイルが最後まで解析されていない場合は nil を返します。 -
スレッド (9001.0)
-
スレッド スレッドとはメモリ空間を共有して同時に実行される制御の流れです。 Ruby ではスレッドはThread クラスのインスタンスとして表されます。
スレッド
スレッドとはメモリ空間を共有して同時に実行される制御の流れです。
Ruby ではスレッドはThread クラスのインスタンスとして表されます。
=== 実装
ネイティブスレッドを用いて実装されていますが、
現在の実装では Ruby VM は Giant VM lock (GVL) を有しており、同時に実行される
ネイティブスレッドは常にひとつです。
ただし、IO 関連のブロックする可能性があるシステムコールを行う場合には
GVL を解放します。その場合にはスレッドは同時に実行され得ます。
また拡張ライブラリから GVL を操作できるので、複数のスレッドを
同時に実行するような拡... -
Open3
. # popen3(*cmd) -> [IO , IO , IO , Thread] (409.0) -
外部プログラム cmd を実行し、そのプロセスの標準入力、標準出力、標準エラー 出力に接続されたパイプと実行したプロセスを待つためのスレッドを 4 要素の 配列で返します。
外部プログラム cmd を実行し、そのプロセスの標準入力、標準出力、標準エラー
出力に接続されたパイプと実行したプロセスを待つためのスレッドを 4 要素の
配列で返します。
require 'open3'
stdin, stdout, stderr, wait_thr = *Open3.popen3("/usr/bin/nroff -man")
@param cmd 実行するコマンドを指定します。
@return ブロックを指定した場合はブロックの最後に評価された値を返します。
ブロックを指定しなかった場合は標準入力、標準出力、標準エラー出
力と... -
void rb
_ define _ attr(VALUE klass , const char *name , int read , int write) (349.0) -
クラス klass にメソッド name と name= を定義します。 read が真のときは name を定義し、 write が真のときは name= を定義します。
クラス klass にメソッド name と name= を定義します。
read が真のときは name を定義し、
write が真のときは name= を定義します。 -
PStore
# transaction(read _ only = false) {|pstore| . . . } -> object (340.0) -
トランザクションに入ります。 このブロックの中でのみデータベースの読み書きができます。
トランザクションに入ります。
このブロックの中でのみデータベースの読み書きができます。
読み込み専用のトランザクションが使用可能です。
@param read_only 真を指定すると、読み込み専用のトランザクションになります。
@return ブロックで最後に評価した値を返します。
@raise PStore::Error read_only を真にしたときに、データベースを変更しようした場合に発生します。
例:
require 'pstore'
db = PStore.new("/tmp/foo")
db.transaction do
p db.roots... -
IO
. select(reads , writes = [] , excepts = [] , timeout = nil) -> [[IO]] | nil (319.0) -
select(2) を実行します。
select(2) を実行します。
与えられた入力/出力/例外待ちの IO オブジェクトの中から準備ができたものを
それぞれ配列にして、配列の配列として返します。
タイムアウトした時には nil を返します。
@param reads 入力待ちする IO オブジェクトの配列を渡します。
@param writes 出力待ちする IO オブジェクトの配列を渡します。
@param excepts 例外待ちする IO オブジェクトの配列を渡します。
@param timeout タイムアウトまでの時間を表す数値または nil を指定します。数値で指定したときの単位は秒です。nil を... -
Open3
. # pipeline _ r(*cmds) -> [IO , [Thread]] (319.0) -
指定したコマンドのリストをパイプで繋いで順番に実行します。最後の コマンドの標準出力を受けとる事ができます。
指定したコマンドのリストをパイプで繋いで順番に実行します。最後の
コマンドの標準出力を受けとる事ができます。
@param cmds 実行するコマンドのリストを指定します。それぞれのコマンドは
以下のように String か Array で指定します。
commandline にはコマンド全体(例. "nroff -man")を表す
String を指定します。
options には Hash で指定します。
env には環境変数を Hash で指定します。
... -
Open3
. # pipeline _ rw(*cmds) -> [IO , IO , [Thread]] (319.0) -
指定したコマンドのリストをパイプで繋いで順番に実行します。最初の コマンドの標準入力に書き込む事も最後のコマンドの標準出力を受けとる事も できます。
指定したコマンドのリストをパイプで繋いで順番に実行します。最初の
コマンドの標準入力に書き込む事も最後のコマンドの標準出力を受けとる事も
できます。
@param cmds 実行するコマンドのリストを指定します。それぞれのコマンドは
以下のように String か Array で指定します。
commandline にはコマンド全体(例. "nroff -man")を表す
String を指定します。
options には Hash で指定します。
env には環境変数を... -
IO
. pipe {|read _ io , write _ io| . . . } -> object (313.0) -
pipe(2) を実行して、相互につながった2つの IO オブジェクトを要素とする配列を返します。
pipe(2) を実行して、相互につながった2つの
IO オブジェクトを要素とする配列を返します。
戻り値の配列は最初の要素が読み込み側で、次の要素が書き込み側です。
ブロックが渡された場合は、そのブロックに2つの IO オブジェクトが渡され、
ブロックの返り値がこのメソッドの返り値となります。
ブロック終了時に IO オブジェクトがもし close されていないならば
close します(close されていてるオブジェクトはそのままです)。
得られる2つの IO オブジェクトのエンコーディングを引数で指定することが
できます。
@param enc_str 読み込み側の外部エンコ... -
IO
. pipe(enc _ str , **opts) {|read _ io , write _ io| . . . } -> object (313.0) -
pipe(2) を実行して、相互につながった2つの IO オブジェクトを要素とする配列を返します。
pipe(2) を実行して、相互につながった2つの
IO オブジェクトを要素とする配列を返します。
戻り値の配列は最初の要素が読み込み側で、次の要素が書き込み側です。
ブロックが渡された場合は、そのブロックに2つの IO オブジェクトが渡され、
ブロックの返り値がこのメソッドの返り値となります。
ブロック終了時に IO オブジェクトがもし close されていないならば
close します(close されていてるオブジェクトはそのままです)。
得られる2つの IO オブジェクトのエンコーディングを引数で指定することが
できます。
@param enc_str 読み込み側の外部エンコ... -
IO
. pipe(ext _ enc) {|read _ io , write _ io| . . . } -> object (313.0) -
pipe(2) を実行して、相互につながった2つの IO オブジェクトを要素とする配列を返します。
pipe(2) を実行して、相互につながった2つの
IO オブジェクトを要素とする配列を返します。
戻り値の配列は最初の要素が読み込み側で、次の要素が書き込み側です。
ブロックが渡された場合は、そのブロックに2つの IO オブジェクトが渡され、
ブロックの返り値がこのメソッドの返り値となります。
ブロック終了時に IO オブジェクトがもし close されていないならば
close します(close されていてるオブジェクトはそのままです)。
得られる2つの IO オブジェクトのエンコーディングを引数で指定することが
できます。
@param enc_str 読み込み側の外部エンコ... -
IO
. pipe(ext _ enc , int _ enc , **opts) {|read _ io , write _ io| . . . } -> object (313.0) -
pipe(2) を実行して、相互につながった2つの IO オブジェクトを要素とする配列を返します。
pipe(2) を実行して、相互につながった2つの
IO オブジェクトを要素とする配列を返します。
戻り値の配列は最初の要素が読み込み側で、次の要素が書き込み側です。
ブロックが渡された場合は、そのブロックに2つの IO オブジェクトが渡され、
ブロックの返り値がこのメソッドの返り値となります。
ブロック終了時に IO オブジェクトがもし close されていないならば
close します(close されていてるオブジェクトはそのままです)。
得られる2つの IO オブジェクトのエンコーディングを引数で指定することが
できます。
@param enc_str 読み込み側の外部エンコ... -
Win32
:: Registry . new(key , subkey , desired = KEY _ READ , opt = REG _ OPTION _ RESERVED) (313.0) -
@todo
@todo
レジストリキー key 下のキー subkey を開き,
開いたキーを表す Win32::Registry オブジェクトを返します。
key は親のキーを Win32::Registry オブジェクトで指定します。
親のキーには定義済キー HKEY_* を使用できます (⇒Win32::Registry::Constants)
desired はアクセスマスクです。opt はキーのオプションです。
詳細は以下の MSDN Library を参照してください。
* Registry Key Security and Access Rights: http://msdn.mic... -
Win32
:: Registry . new(key , subkey , desired = KEY _ READ , opt = REG _ OPTION _ RESERVED) {|reg| . . . } (313.0) -
@todo
@todo
レジストリキー key 下のキー subkey を開き,
開いたキーを表す Win32::Registry オブジェクトを返します。
key は親のキーを Win32::Registry オブジェクトで指定します。
親のキーには定義済キー HKEY_* を使用できます (⇒Win32::Registry::Constants)
desired はアクセスマスクです。opt はキーのオプションです。
詳細は以下の MSDN Library を参照してください。
* Registry Key Security and Access Rights: http://msdn.mic... -
Win32
:: Registry . open(key , subkey , desired = KEY _ READ , opt = REG _ OPTION _ RESERVED) (313.0) -
@todo
@todo
レジストリキー key 下のキー subkey を開き,
開いたキーを表す Win32::Registry オブジェクトを返します。
key は親のキーを Win32::Registry オブジェクトで指定します。
親のキーには定義済キー HKEY_* を使用できます (⇒Win32::Registry::Constants)
desired はアクセスマスクです。opt はキーのオプションです。
詳細は以下の MSDN Library を参照してください。
* Registry Key Security and Access Rights: http://msdn.mic...