我有一个Akka消息引擎,可以在一天中发送数百万条消息,包括短信和电子邮件。我需要介绍一种新的消息传递类型(PushNotification),它包括让每个请求使用一个REST API (它还将处理数百万个请求)。我认为使用Webservice是一个阻塞操作,所以从我所读到的内容来看,我需要为这个新的Actor添加一个单独的分派器,我的问题是,它一定要像这里提到的那样是具有固定池大小的线程池执行器吗
我有一个由100个运行的actor组成的actor池,它们共享一个CorePoolSize设置为100的工作窃取调度程序。当这5条消息完成后,接下来的5条消息将再次由这5个Actor处理,依此类推。为什么我的19条消息不能并行运行,我在这里遗漏了什么?我的代码基本上是这样的: val dispatcher = Dispatchers.newExecutorBasedEventDrivenWor
我有一小部分参与者(用Java语言编写,使用Akka类型的API),它们利用TimerScheduler将消息调度给它们自己。我想写一些测试来检查它们之间的交互。当使用ActorTestKit recommended in the documentation时,它可以使用普通计时器执行它们,这意味着当参与者在10秒内调度给自己一条消息时,测试必须持续10秒。为了加快测试速度,我想使用虚拟时间进行测试,其中测试中<em