akka-dispatcher

    0热度

    1回答

    使用Akka调度员处理期货

    我有一个基于Spray的HTTP服务。我有一个流在这个HTTP应用程序中运行。现在，由于这个流做了很多I/O，我决定使用一个单独的线程池。我查阅了Akka文档，看看我能做些什么，以便我的线程池可配置。我遇到了Akka的Dispatcher概念。于是，我就在我的application.conf如下使用它： akka { io-dispatcher { # Dispatcher i
    scala akka akka-dispatcher 2016-05-03

    0热度

    1回答

    演员中的阻止操作不占用所有默认调度员

    我最近正在学习Akka Actor。我读了演员中调度员的文件。我对演员中的阻止操作感到好奇。文档中最后的topic描述了如何解决该问题。我试图重现文档中的示例实验。 这里是我的代码： package dispatcher import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory obje
    scala akka actor blocking akka-dispatcher 2017-08-04

    2热度

    1回答

    Akka Streams反应性Kafka - OutOfMemoryError在高负载下

    我正在运行一个Akka Streams Reactive Kafka应用程序，它应该在重负载下正常工作。运行该应用程序大约10分钟后，该应用程序将以OutOfMemoryError停机。我试图调试堆转储，发现akka.dispatch.Dispatcher正在占用〜5GB的内存。以下是我的配置文件。 阿卡版本：2.4.18 反应卡夫卡版本：2.4.18 1. application.conf： c
    scala akka akka-stream reactive-kafka akka-dispatcher 2017-09-27

    2热度

    1回答

    阿卡均衡池中有可变大小的线程池执行人

    这里是我的使用情况： 我想创建一个大小为x的平衡池路由器（x是实例的数量/该在确定routees运行时），每个路由都有自己的专用线程。 每个路线预计将执行阻止操作。 Akka文档解释说您不能更改平衡池的调度程序。这就消除了使用固定调度程序的选项（它将完成我所需要的任务，每个routee的大小为1的线程池）。 从Akka documentation： 的BalancingPool自动使用其route
    scala akka threadpoolexecutor akka-actor akka-dispatcher 2016-12-16
最新问题