99件ヒット
[1-99件を表示]
(0.014秒)
種類
- インスタンスメソッド (88)
- クラス (11)
ライブラリ
-
rinda
/ rinda (44) -
rinda
/ tuplespace (55)
クラス
-
Rinda
:: TupleSpace (44) -
Rinda
:: TupleSpaceProxy (44)
検索結果
先頭5件
-
Rinda
:: TupleSpace (18018.0) -
Tuple Space を表すクラスです。
...Tuple Space を表すクラスです。
このクラスのインスタンスを
drb を経由して公開することで
タプルスペースを他のプロセスからアクセスさせることができるようになります。
タプルスペースを drb 経由で利用する側は
DRb::DR......でこのオブジェクトのリモートオブジェクトを
取得し、Rinda::TupleSpaceProxy をかぶせることで利用します。
===[a:renewer] タプルの寿命と renewer
タプルを Rinda::TupleSpace#write などで追加するときにその寿命を
秒数で指定すること......過ぎてもすぐには削除されず、Rinda::TupleSpace.new の
引数で指定した秒数ごとに「掃除用スレッド」が動き、それによって
cancel されたタプルや期限切れになったタプルが削除されます。
sec には秒数の代わりに renewer を指定... -
Rinda
:: TupleSpace # notify(event , pattern , sec = nil) -> Rinda :: NotifyTemplateEntry (3155.0) -
event で指定した種類のイベントの監視を開始します。
...のメソッドの返り値の Rinda::NotifyTemplateEntry を経由し、
Rinda::NotifyTemplateEntry#each を用いて報告を受け取ります。
sec で監視期間を秒数で指定できます。 nil で無限に監視し続けます。
event として以下の3つを指定できます。......ram sec 監視期間の長さ(秒数)
=== 例
require 'rinda/tuplespace'
tuplespace = Rinda::TupleSpace.new
observer = tuplespace.notify("write", ["xyz", nil, nil])
Therad.new do
observer.each{|event, tuple| p event, tuple }
end
tuplespace.write(["xyz", 0, 1])
tuplespace.w......rite(["pqr", 0, 1])
tuplespace.write(["xyz", 4, 2])... -
Rinda
:: TupleSpace # read(tuple , sec=nil) -> [Array|Hash] (3125.0) -
タプルスペース内の tuple にマッチするタプルを一つコピーして返します。
...ルスペースに
投入されるまで待ちます。
sec でタイムアウト秒数を指定できます。
待ち時間が sec 秒を過ぎた時には read をあきらめ
例外 Rinda::RequestExpiredError を発生させます。
sec に nil を指定するとタイムアウトせずに無......限に待ち続けます。
@param tuple タプルのパターン
@param sec タイムアウト秒数
@raise Rinda::RequestExpiredError read がタイムアウトした場合に発生します
@raise Ridna::RequestCanceledError read が何らかの理由でキャンセルされた場合に発生し... -
Rinda
:: TupleSpace # take(tuple , sec = nil) -> Array | Hash (3125.0) -
tuple にマッチするタプルをタプルスペースから取り出して返します。
...ルスペースに
投入されるまで待ちます。
sec でタイムアウト秒数を指定できます。
待ち時間が sec 秒を過ぎた時には take をあきらめ
例外 Rinda::RequestExpiredError を発生させます。
sec に nil を指定するとタイムアウトせずに無......限に待ち続けます。
@param tuple タプルのパターン
@param sec タイムアウト秒数
@raise Rinda::RequestExpiredError take がタイムアウトした場合に発生します
@raise Ridna::RequestCanceledError take が何らかの理由でキャンセルされた場合に発生し... -
Rinda
:: TupleSpace # write(tuple , sec = nil) -> Rinda :: TupleEntry (3119.0) -
tuple をタプルスペースに加えます。 tuple を管理するための Rinda::TupleEntry オブジェクトを返します。
...加えます。
tuple を管理するための Rinda::TupleEntry オブジェクトを返します。
sec で追加したタプルの有効期限を指定できます。
追加されてから sec 秒過ぎたタプルはタプルスペースから削除されます。
nil は無限を意味し、......があります。
詳しくはRinda::TupleEntry のエントリーを見てください。
@param tuple 追加する tuple (配列かHash)
@param sec 有効期限(秒数)
@raise Rinda::InvalidHashTupleKey 不正な Hash tuple (キーが文字列以外のもの)を
追加しようとする... -
Rinda
:: TupleSpaceProxy # notify(ev , tuple , sec = nil) -> Rinda :: NotifyTemplateEntry (3119.0) -
event で指定した種類のイベントの監視を開始します。
...トオブジェクトの Rinda::TupleSpace#notify にフォワードされます。
詳細は Rinda::TupleSpace#notify 参照してください
@param event 監視対象のイベント(文字列)
@param pattern 監視対象となるタプルのパターン
@param sec 監視期間の長さ(秒数)... -
Rinda
:: TupleSpaceProxy # read(tuple , sec=nil) -> [Array|Hash] (3119.0) -
タプルスペース内の tuple にマッチするタプルを一つコピーして返します。
...ます。
内部的にはリモートオブジェクトの Rinda::TupleSpace#read にフォワードされます。
詳細は Rinda::TupleSpace#read を参照してください。
@param tuple タプルのパターン
@param sec タイムアウト秒数
@raise Rinda::RequestExpiredError read が... -
Rinda
:: TupleSpaceProxy # take(tuple , sec = nil) -> Array | Hash (3119.0) -
tuple にマッチするタプルをタプルスペースから取り出して返します。
...ます。
内部的にはリモートオブジェクトの Rinda::TupleSpace#take にフォワードされます。
詳細は Rinda::TupleSpace#take を参照してください。
@param tuple タプルのパターン
@param sec タイムアウト秒数
@raise Rinda::RequestExpiredError take が... -
Rinda
:: TupleSpaceProxy # write(tuple , sec = nil) -> Rinda :: TupleEntry (3119.0) -
tuple をタプルスペースに加えます。 tuple を管理するための Rinda::TupleEntry オブジェクトを返します。
...eEntry オブジェクトを返します。
内部的にはリモートオブジェクトの Rinda::TupleSpace#write にフォワードされます。
詳細は Rinda::TupleSpace#write を参照してください。
@param tuple 追加する tuple (配列かHash)
@param sec 有効期限(秒数)...