種類
ライブラリ
クラス
-
DRb
:: DRbServer (11) - Fiber (22)
-
IRB
:: Context (11) - Monitor (32)
- Mutex (8)
-
Net
:: IMAP (22) -
Net
:: IMAP :: ThreadMember (11) - PStore (11)
- Socket (22)
- Thread (550)
-
Thread
:: ConditionVariable (33) -
Thread
:: Mutex (45) -
Thread
:: Queue (77) -
Thread
:: SizedQueue (75) - ThreadGroup (44)
- ThreadsWait (60)
- TracePoint (11)
- Tracer (33)
- WIN32OLE (11)
-
YAML
:: Store (16)
キーワード
-
$ -d (11) -
$ DEBUG (11) -
$ SAFE (5) -
1
. 6 . 8から1 . 8 . 0への変更点(まとめ) (11) - << (22)
-
CP
_ THREAD _ ACP (11) - ConditionVariable (11)
- DEBUG (11)
- DEBUG= (11)
- Default (11)
- Enumerator (11)
- ErrNoWaitingThread (6)
- Fiber (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) - Queue (11)
- Ruby用語集 (11)
- ThreadError (11)
- ThreadGroup (11)
- ThreadMember (11)
- ThreadsWait (6)
- WIN32OLE (11)
- [] (11)
- []= (11)
-
abort
_ on _ exception (22) -
abort
_ on _ exception= (22) - add (11)
-
add
_ trace _ func (11) - alive? (11)
-
all
_ waits (18) - backtrace (11)
-
backtrace
_ locations (22) - broadcast (11)
- children (11)
- close (9)
- current (11)
- debug (11)
- deq (22)
- detach (11)
-
display
_ thread _ id (11) -
display
_ thread _ id= (11) -
display
_ thread _ id? (11) - drb (11)
-
drb
/ extservm (11) - empty? (6)
- enclose (11)
- enq (22)
- enter (11)
- exclusive (11)
- exit (33)
- fetch (7)
- finished? (6)
- fork (11)
- group (11)
-
handle
_ interrupt (11) - irb (11)
- join (28)
-
join
_ nowait (6) - key? (11)
- keys (11)
- kill (22)
- list (22)
- lock (11)
- main (11)
-
mon
_ enter (16) -
mon
_ exit (5) - monitor (11)
-
net
/ imap (11) - new (55)
-
next
_ wait (6) -
num
_ waiting (11) - owned? (11)
- pass (11)
-
pending
_ interrupt? (11) -
pipeline
_ r (22) -
pipeline
_ rw (22) -
pipeline
_ w (22) - pop (22)
- popen2 (22)
- popen2e (22)
- popen3 (22)
- priority (11)
- priority= (11)
- push (22)
- raise (11)
-
rb
_ gc _ mark _ threads (11) -
rb
_ thread _ alone (11) -
rb
_ thread _ current (11) -
rb
_ thread _ main (11) -
rb
_ thread _ restore _ context (11) -
rb
_ thread _ run (11) -
rb
_ thread _ save _ context (11) -
rb
_ thread _ schedule (11) -
rb
_ thread _ select (1) -
rb
_ thread _ start _ timer (11) -
rb
_ thread _ stop (11) -
rb
_ thread _ stop _ timer (11) -
rb
_ thread _ wait _ fd (11) -
rb
_ thread _ wait _ for (11) -
rb
_ thread _ wakeup (11) -
report
_ on _ exception (16) -
report
_ on _ exception= (16) - resume (11)
-
rinda
/ rinda (11) -
ruby 1
. 6 feature (11) -
ruby 1
. 8 . 4 feature (11) -
ruby 1
. 8 . 5 feature (11) - run (11)
-
safe
_ level (5) -
set
_ trace _ func (11) - shift (22)
- signal (11)
- sleep (33)
- start (11)
- status (11)
- stop (11)
- stop? (11)
- synchronize (9)
-
tcp
_ server _ loop (22) - terminate (11)
- thread (46)
-
thread
_ variable? (11) -
thread
_ variable _ get (11) -
thread
_ variable _ set (11) - threads (6)
- timeout (41)
- transfer (11)
-
uid
_ thread (11) - unlock (11)
- value (11)
- wait (11)
- wakeup (11)
- セキュリティモデル (11)
- 終了処理 (11)
検索結果
先頭5件
-
Fiber
# transfer(*args) -> object (12.0) -
自身が表すファイバーへコンテキストを切り替えます。
...られた引数を返します。
@raise FiberError 自身が既に終了している場合、コンテキストの切り替えが Thread クラスが表すスレッド間をまたがる場合、
Fiber#resume を呼んだファイバーがその親か先祖である場合に発生... -
Mutex
# sleep(timeout = nil) -> Integer (12.0) -
与えられた秒数の間ロックを解除してスリープして、実行後にまたロックします。
...定します。省略するとスリープし続けます。
@return スリープしていた秒数を返します。
@raise ThreadError 自身がカレントスレッドによってロックされていない場合に発生します。
[注意] 2.0 以降ではスリープ中でも、シグナ......ルを受信した場合などに実行が再
開(spurious wakeup)される場合がある点に注意してください。
//emlist[例][ruby]{
m = Mutex.new
th = Thread.new do
m.lock
m.sleep(2)
end
th.status # => "run"
sleep 1
th.status # => "sleep"
sleep 1
th.status # => false
//}... -
drb (12.0)
-
分散オブジェクトプログラミングのためのライブラリです。
...T=TimeServer.new
# サーバを起動する
DRb.start_service(SERVER_URI, FRONT_OBJECT, :safe_level => 1)
# DRb のスレッドが終了するのを待つ
DRb.thread.join
==== クライアント側コード
require 'drb/drb'
# 接続先の URI
SERVER_URI="druby://localhost:8787"... -
rinda
/ rinda (12.0) -
Rubyで実装されたタプルスペース(Tuple Space)を扱うためのライブラリです。
...すが、
適切な同期処理を実現することは困難をともないます。
このパターンにおいては、複数の並列単位(スレッド/プロセス)間の通信をすべて
タプルスペースという領域を経由して行います。これによって
プロセス間の......_ts.rb
require 'drb/drb'
require 'rinda/tuplespace'
uri = ARGV.shift
DRb.start_service(uri, Rinda::TupleSpace.new)
puts DRb.uri
DRb.thread.join
# rindas.rb
require 'drb/drb'
require 'rinda/rinda'
def do_it(v)
puts "do_it(#{v})"
v + v
end
uri = ARGV.shift ||... -
Open3
. # pipeline _ r(*cmds) {|last _ stdout , wait _ thrs| . . . } -> () (7.0) -
指定したコマンドのリストをパイプで繋いで順番に実行します。最後の コマンドの標準出力を受けとる事ができます。
...ロックを指定しなかった場合は最後に実行するコマンドの標準出力、
実行したプロセスを待つためのスレッドの配列を配列で返します。
例:
require "open3"
Open3.pipeline_r("yes", "head -10") {|r, ts|
p r.read #=> "y\ny\ny\n... -
Open3
. # pipeline _ rw(*cmds) {|first _ stdin , last _ stdout , wait _ thrs| . . . } -> () (7.0) -
指定したコマンドのリストをパイプで繋いで順番に実行します。最初の コマンドの標準入力に書き込む事も最後のコマンドの標準出力を受けとる事も できます。
...るコマンドの標準入力
と最後に実行するコマンドの標準出力、実行したプロセスを待つため
のスレッドの配列を配列で返します。
例:
require "open3"
Open3.pipeline_rw("sort", "cat -n") {|stdin, stdout, wait_thrs|
stdin.put... -
Open3
. # pipeline _ w(*cmds) {|first _ stdin , wait _ thrs| . . . } -> () (7.0) -
指定したコマンドのリストをパイプで繋いで順番に実行します。最初の コマンドの標準入力に書き込む事ができます。
...ロックを指定しなかった場合は最初に実行するコマンドの標準入力、
実行したプロセスを待つためのスレッドの配列を配列で返します。
例:
require "open3"
Open3.pipeline_w("bzip2 -c", :out=>"/tmp/hello.bz2") {|w, ts|
w.puts "hel... -
Open3
. # popen2(*cmd) {|stdin , stdout , wait _ thr| . . . } -> () (7.0) -
cmdで指定されたコマンドを実行し、そのプロセスの標準入力・標準出力にパイ プをつなぎます。Open3.popen3に似ていますが、標準エラーを扱いません。
...クを指定しなかった場合は標準入力、標準出力に接続されたパ
イプと実行したプロセスを待つためのスレッドを返します。
Open3.#popen3と同様に引数に環境変数とオプションを指定してコマンド
を実行する事ができま... -
Open3
. # popen2e(*cmd) {|stdin , stdout _ and _ stderr , wait _ thr| . . . } -> () (7.0) -
cmdで指定されたコマンドを実行し、そのプロセスの標準入力・標準出力と標準 エラーにパイプをつなぎます。Open3.popen3に似ていますが、標準出力と標準 エラーが1つの変数で扱われます。
...かった場合は標準入力、標準出力と標準エラーに
接続されたパイプと実行したプロセスを待つためのスレッドを返しま
す。
Open3.#popen3と同様に引数に環境変数とオプションを指定してコマンド
を実行する事が...