リクエストをブロックするためのAkkaアクタープール

Question

ブロックプールを使用してブロックリクエストを作成しようとしています。 問題は、各リクエストがプール全体をブロックしており、アイテムが順番に処理されていることです。 これが可能であるかどうかは不明です。誰かが

city-dispatcher { 
    type = Dispatcher 
    executor = "thread-pool-executor" 
    thread-pool-executor { 
    fixed-pool-size = 16 
    } 
    throughput = 100 
} 

を助けてくださいとJava

 Props props = Props.create(CityDataProcessorActor.class, psRespHolder).withDispatcher("akka.actor.city-dispatcher"); 

    SmallestMailboxPool pool = new SmallestMailboxPool(10); 

    ActorRef cityRequestActorPool = actorSystem.actorOf(pool.props(props), "city-request-route"); 
    for (String city : citiesArray) { 
     Future<Object> future = Patterns.ask(cityRequestActorPool, new CityCommand(city.trim()), timeout); 
     Object results = Await.result(future, duration); 
     log.info(results.toString()); 
    } 

Answer 1

モン・カラマリのコメントはまさに正しいです。ここに実装があります。あなたがそれらを作成すると、それは先物のリストを作成します。収集された先物を順次ブロックして、それぞれを記録します。後の先物が同様の時期に完了したならば、反復が進むにつれて待つことは自明になるはずです。

.... 
Array<Future<Object>> futures = new ArrayList<>(); 
for (String city : citiesArray) { 
    Future<Object> future = Patterns.ask(cityRequestActorPool, new CityCommand(city.trim()), timeout); 
    futures.add(future); 
} 

for (<Future<Object>> f :futures){ 
    Object results = Await.result(f, duration); 
    log.info(results.toString()); 
} 

Answer 2

@Monイカは Object results = Await.result(future, duration);を述べたように、ブロッキング・コールです。 `コードのこの部分がブロックしている、あなたはコールバックで

future onComplete{ case Success()=> println(result) case Failure()=> println("some error") }