特牛生活网

scala编写Akka并发控制线程数量简单示例_akka设置最大并发数-CSDN博客

网友收藏
文章浏览阅读451次。akka设计模式首先就是设计一个管理者,来管理控制线程的并发taskTotal是并发执行的总任务数taskExecute是已经执行过的任务数根据传入的并发数量来控制我们一开始要创建多少个工作通过.actorOf来创建一个worker的ActorRef,注意名字不能重复,并且将自己的ActorRef传过去,用来接收回馈的信息每创建完一个ActorRef,我们从任务队列中获取一个任务,让它把任务消息发给workerActor去执行任务worker执行完之后反馈执行情况,将任务执行数量和总任务数对_akka设置最大并发数