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
最新問題