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

发布时间：2020-12-16 18:10:26 所属栏目：安全来源：网络整理

导读：我有一个高CPU /内存绑定任务,我希望我的 Scala程序并行执行.所以,我正在使用Actors框架(在while(true)循环中使用receive).我在actor上调用start方法并向其发送数千条消息进行处理. 在执行程序期间(大约需要一个小时),只使用了100 – 120％的CPU.这台机器有8

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

在执行程序期间(大约需要一个小时),只使用了100 – 120％的CPU.这台机器有8个核心.演员不应该产生多个线程来耗尽所有8个核心,我应该看到使用率接近800％？

或者我应该实例化8个演员并将每个消息发送给它(或者更确切地说是从一些并发队列中读取所有消息)？

谢谢.

解决方法

不.保证单个actor一次只在一个线程上执行,因此不需要同步对其状态的访问.如果要跨多个核心传播问题,则需要多个角色.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!