CODEWITHSUNDEEP
akka.net
Damian
Damian

Reputation: 2789

How do I wait for all work to complete in Akka.Net?

I have successfully sent work to a pool of actors to perform my work, but now I want to do some aggregation on the results returned by all the workers. How do I know that everyone is done?

The best I have come up with is to maintain a set of requests ids and wait for that set to go to zero, but this seems inelegant.

Upvotes: 11

Views: 2219

Answers (1)

AndrewS
AndrewS

Reputation: 1385

Generally, you want to use what we call the "Commander" pattern for this. Essentially, you have one stateful actor (the Commander) that is responsible for starting and monitoring the task. You then farm out the actual work across the actor pool, and have them report back to the Commander as they finish. The commander can then track the progress of the job by calculating # completions / size of worker pool.

This way, the workers can be monitored and restarted independently as they do the work, but all the precious task-level state and information lives in the Commander (this is called the "Error Kernel pattern")

You can see an example of this in the Akka.NET scalable webcrawler demo.

Upvotes: 10

Related Questions