class Rinda::TupleBag
TupleBag is an unordered collection of tuples. It is the basis of Tuplespace.
Public Instance Methods
# File lib/rinda/tuplespace.rb, line 341 def delete(tuple) key = bin_key(tuple) bin = @hash[key] return nil unless bin bin.delete(tuple) @hash.delete(key) if bin.empty? tuple end
Removes tuple from the TupleBag.
# File lib/rinda/tuplespace.rb, line 381
def delete_unless_alive
deleted = []
@hash.each do |key, bin|
bin.delete_if do |tuple|
if tuple.alive?
false
else
deleted.push(tuple)
true
end
end
end
deleted
end Delete tuples which dead tuples from the TupleBag, returning the deleted tuples.
# File lib/rinda/tuplespace.rb, line 361
def find(template)
bin_for_find(template).find do |tuple|
tuple.alive? && template.match(tuple)
end
end Finds a live tuple that matches template.
# File lib/rinda/tuplespace.rb, line 352
def find_all(template)
bin_for_find(template).find_all do |tuple|
tuple.alive? && template.match(tuple)
end
end Finds all live tuples that match template.
# File lib/rinda/tuplespace.rb, line 371
def find_all_template(tuple)
@enum.find_all do |template|
template.alive? && template.match(tuple)
end
end Finds all tuples in the TupleBag which when treated as templates, match tuple and are alive.
# File lib/rinda/tuplespace.rb, line 323
def has_expires?
@enum.find do |tuple|
tuple.expires
end
end true if the TupleBag to see if it has any expired entries.
# File lib/rinda/tuplespace.rb, line 332 def push(tuple) key = bin_key(tuple) @hash[key] ||= TupleBin.new @hash[key].add(tuple) end
Add tuple to the TupleBag.
Private Instance Methods
# File lib/rinda/tuplespace.rb, line 412 def bin_for_find(template) key = bin_key(template) key ? @hash.fetch(key, []) : @enum end
# File lib/rinda/tuplespace.rb, line 403
def bin_key(tuple)
head = tuple[0]
if head.class == Symbol
return head
else
false
end
end # File lib/rinda/tuplespace.rb, line 397
def each_entry(&blk)
@hash.each do |k, v|
v.each(&blk)
end
end
Ruby Core © 1993–2017 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.