by having Mailbox extend ForkJoinTask and using the fact that ForkJoinTask.exec when returning false does not set completion on the task, so it is free to be resubmitted to the ForkJoinPool without reinitialization. Also adds the ability to use fork() when the currentThread is a worker thread of the pool that we want to execute on. Adds a JMH benchmark for both the ping-pong performance and pipelined throughput. Conflicts: project/AkkaBuild.scala |
||
|---|---|---|
| .. | ||
| actor | ||
| event | ||
| persistence | ||