如何使用 Scala 演员充分利用所有核心？

Question

我有一个高 CPU/内存绑定任务，我希望我的 Scala 程序并行执行。所以，我正在使用 Actors 框架（在 while(true) 循环中使用接收）。我在 actor 上调用 start 方法并向其发送数千条消息以进行处理。

在程序执行期间（大约需要一个小时），只使用了 100 - 120% 的 CPU。该机器有8个核心。演员不应该产生多个线程来用完所有 8 个内核，我应该看到使用率接近 800%？

或者我应该实例化 8 个参与者并分别向它发送一些消息（或者更确切地说让它们都从某个并发队列中读取）？

谢谢。

Answer 1

不。保证单个参与者一次只在一个线程上执行，因此对其状态的访问不需要同步。如果您想将问题分散到多个核心，则需要多个参与者。