0

テスト例を入手しました。

ここで、MyBoss は、その作業の一部が停止しなければならないにもかかわらず、難しいが粒状化された作業を完了する必要があります。

require 'celluloid'
require 'celluloid/autostart'

class MyActor
  include Celluloid

  attr_reader :name, :peace_of_work

  def initialize
    @name = "actor_#{self.object_id}"
    print "Created actor '#{@name}'\n"
  end

  def run(peace_of_work)
    @peace_of_work = peace_of_work
    sleep 0.1
    raise "Actor '#{@name}' is dying" if rand(0..1.0) < 0.1
    print "Actor '#{@name}' has #{peace_of_work}-th peace of work done\n"
  end
end

class MyBoss
  def initialize
  end

  def run work_peaces
    @work_peaces = work_peaces
    @actor_pool = MyActor.pool(size: 10, args: [])
    work_peaces.each do |peace_of_work|
      @actor_pool.async.run(peace_of_work)
    end
  end
end

if __FILE__ == $PROGRAM_NAME
  boss = MyBoss.new
  work_peaces = (0..999).to_a
  boss.run(work_peaces)
  sleep
end

俳優は散発的に死ぬ。明らかに、台無しにされたワーク ピースをやり直す必要があります。アクターがプールにいる場合、アクターの死亡をトラップするにはどうすればよいですか? 知らせMyActor.pool(size: 10, args: [])

4

1 に答える 1

0

これは、以下のリンクで解決されている既知の問題です。

要点は次のとおりです。

trap_exitすでにPoolマネージャー自体で機能しています。idleアクターが死亡すると、とbusyのセットから取り出しPool、新しいアクターを as としてスポーンする必要がありますidle。そうしないと、Poolが不安定になります。

Pool死んだアクターの状況を修正できるようになった後、2 番目のメソッドを注入して実行する必要があります。

于 2015-07-12T07:26:06.670 に答える