Rdv for CSP study

rdv_csp.rb

require 'rinda/tuplespace'

class Rdv
  def initialize(ts=nil)
    @ts = ts || Rinda::TupleSpace.new
  end

  def select?(*chan)
    template = Template.new(*chan)
    t, k = @ts.take([template, nil])
    c = template.chan(t)
    @ts.write(['chan', k, c])
    value = @ts.take(['value', k, c, nil]).last
    return c, value
  end

  def select!(*chan)
    template = Template.new(*chan)
    key = Object.new
    @ts.write([template, key])
    _, _, c = @ts.take(['chan', key, nil])
    value = yield(c)
    @ts.write(['value', key, c, value])
    key
  end
end

class Template
  def initialize(*chan)
    @ary = chan
  end

  def to_a
    @ary
  end

  def chan(other)
    @ary.intersection(other.to_a).sample
  end

  def ===(other)
    chan(other)
  end
end

if __FILE__ == $0
  RDV = Rdv.new
  5.times do |n|
    Thread.new(n) do
      sleep(rand n)
      pp RDV.select?('a', 'b', 'c')
    end
  end

  5.times do |n|
    Thread.new(n) do
      sleep(rand n)
      pp RDV.select?('b')
    end
  end

  10.times do |n|
    Thread.new(n) do
      pp RDV.select!('a', 'b', 'c') {|c| [n, c]}
    end
  end

  sleep 10
end