類別 Rinda::NotifyTemplateEntry

TupleSpace 變更時,TupleSpace#notify 會傳回 NotifyTemplateEntry 並通知變更。在反覆處理通知時,您可能會收到您訂閱的事件或「關閉」事件。

請參閱 TupleSpace#notify_event 以取得有效的通知類型。

範例

ts = Rinda::TupleSpace.new
observer = ts.notify 'write', [nil]

Thread.start do
  observer.each { |t| p t }
end

3.times { |i| ts.write [i] }

輸出

['write', [0]]
['write', [1]]
['write', [2]]

公開類別方法

new(place, event, tuple, expires=nil) 按一下以切換來源

建立新的 NotifyTemplateEntry,用於監視 place 中與 tuple 相符的 +event+。

呼叫超類別方法 Rinda::TupleEntry::new
# File lib/rinda/tuplespace.rb, line 245
def initialize(place, event, tuple, expires=nil)
  ary = [event, Rinda::Template.new(tuple)]
  super(ary, expires)
  @queue = Thread::Queue.new
  @done = false
end

公開實例方法

each() { |event, tuple| ... } 按一下以切換來源

產生 event/tuple 成對,直到此 NotifyTemplateEntry 過期。

# File lib/rinda/tuplespace.rb, line 273
def each # :yields: event, tuple
  while !@done
    it = pop
    yield(it)
  end
rescue
ensure
  cancel
end
notify(ev) 按一下以切換來源

TupleSpace 呼叫,以通知此 NotifyTemplateEntry 有新的事件。

# File lib/rinda/tuplespace.rb, line 255
def notify(ev)
  @queue.push(ev)
end
pop() 按一下以切換來源

擷取通知。當此 NotifyTemplateEntry 過期時,會引發 RequestExpiredError

# File lib/rinda/tuplespace.rb, line 263
def pop
  raise RequestExpiredError if @done
  it = @queue.pop
  @done = true if it[0] == 'close'
  return it
end