ruby-concurrency / ruby-concurrency/concurrent-ruby
Actor pool terminated event sent as message
Aperta
@pitr-ch ci sta già lavorando.
Dal 24/8/2019.
question
- Lingua principale
- Ruby
- Stelle
- 5.8k
- Fork
- 420
- Merge medio
- 20h 45m
- PR unite (30g)
- 4
Descrizione
- Operating system: Linux
- Ruby implementation: Ruby
concurrent-rubyversion: 1.1.5concurrent-ruby-edgeversion: 0.5.0
Given this code:
require 'concurrent-edge'
class WorkerActor < Concurrent::Actor::RestartingContext
def on_event(event)
puts "#{name} event: #{event.inspect}"
end
end
class Actor < Concurrent::Actor::RestartingContext
def initialize
@worker_pool = Concurrent::Actor::Utils::Pool.spawn('worker_pool', 10) do |index|
WorkerActor.spawn(name: "worker[#{index}]", supervise: true)
end
end
def on_message(message)
puts "#{name} message: #{message.inspect}"
end
def on_event(event)
puts "#{name} event: #{event.inspect}"
end
end
actor = Actor.spawn(name: 'parent')
actor << :terminate!
sleep 0.1
-why does the Actor receive both an event :terminated and a message :terminated? Output from the above:
parent event: [:terminated, nil]
worker[0] event: [:terminated, nil]
worker[1] event: [:terminated, nil]
worker[2] event: [:terminated, nil]
worker[3] event: [:terminated, nil]
worker[4] event: [:terminated, nil]
worker[5] event: [:terminated, nil]
worker[6] event: [:terminated, nil]
worker[7] event: [:terminated, nil]
worker[8] event: [:terminated, nil]
worker[9] event: [:terminated, nil]
parent message: [:terminated, nil]
It only seems to receive a message when I use a Pool. If I replace the #initialize method with:
@worker = WorkerActor.spawn(name: 'worker', supervise: true)
Then the output includes only events and no message:
parent event: [:terminated, nil]
worker event: [:terminated, nil]
Guida per i contributori
Apri la guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Valutazione
Questa issue non è ancora stata valutata.