[ruby-list:21274] Re: agent

咳といいます。

MQ> 折角ですので osv.rb と一緒に使う script も載せます。

MQ> osv.rb は hello.rb を require しないといけないのが
MQ> 美しくないなあ，と思いました。


dRubyで書いてみました。
# telescriptまではほど遠い…。しくしく


□ How to play

プレースは同一のホストでも起こせます。

 ■ host1	プレースの起動
% ruby place.rb
druby://host1:1234      # -> このプレースのURI

 ■ host2	プレースの起動
% ruby place.rb
druby://host2:2345      # -> このプレースのURI

 ■ host3	片道のエージェント。引数に巡回するプレースの列を与える
% ruby hello.rb druby://host1:1234 druby://host2:2345

 ■ host3 	自宅に戻ってくるエージェント。
% ruby home.rb druby://host1:1234 druby://host2:2345


--- place.rb ---
require 'drb'	# http://www2a.biglobe.ne.jp/~seki/ruby/drb-1.1.tar.gz
require 'thread'

class Place
  include DRbUndumped

  def initialize(name)
    @pool = Queue.new
    @th = Thread.start { main_loop }
    @name = name
  end
  attr_reader :name

  def load_agent_code(mod)
#    require('agent/' + File.basename(mod))
    require mod
  end

  def enter(obj)
    @pool.push(obj)
  end

  def exec(obj)
    Thread.start do
      obj.live(self)
    end
  end

  def main_loop
    while(true)
      obj = @pool.pop
      exec(obj)
    end
  end

  private :exec
  private :main_loop
end

if __FILE__ == $0
  DRb.start_service(nil, Place.new($$))
  puts DRb.uri
  DRb.thread.join
end


--- hello.rb ---
class Hello
  def initialize(name, msg)
    @name = name
    @msg = msg
    @places = []
    @report = []
  end
  attr_reader :places
  attr_reader :name
  attr_reader :report

  def live(place)
    @report.push(place.name)
    greeting
    walk
  end

  def greeting
    puts "greeting[#{@name.inspect}]: #{@msg}"
  end

  def walk    
    place = @places.shift
    return unless place
    place.load_agent_code('hello')
    place.enter(self)
  end
end

if __FILE__ == $0
  require 'drb'

  DRb.start_service
  hello = Hello.new($$, 'Hello, World')
  ARGV.each do |uri|
    hello.places.push(DRbObject.new(nil, uri))
  end
  hello.walk
end

--- home.rb ---
require 'drb'
require 'hello'
require 'place'

class HomePlace < Place
  def waiting(agent_name)
    @my_agent_name = agent_name
  end

  def exec(obj)
    if @my_agent_name == obj.name
      puts "Hi, my agent: [#{obj.report.join(', ')}]." 
      exit
    end
    super(obj)
  end
end

if __FILE__ == $0
  place = HomePlace.new($$)
  DRb.start_service(nil, place)
  puts DRb.uri

  hello = Hello.new([$$, place.id], 'Hello, World')
  place.waiting(hello.name)
  ARGV.each do |uri|
    hello.places.push(DRbObject.new(nil, uri))
  end
  hello.places.push(DRbObject.new(place))
  hello.walk

  DRb.thread.join
end