fork e join utilizzando Akka

Question

problema: ho un portafoglio di titoli che devono essere elaborati in modo parallelo. In Java ho usato un threadpool per elaborare ogni sicurezza e utilizzare un latch per il conto alla rovescia. Una volta completato, faccio un po 'di fusione, ecc.

Quindi messaggio al mio SecurityProcessor (che è un attore), e aspetto che tutti i futures siano completati. Alla fine uso un MergeHelper per eseguire la post-elaborazione. Il SecurityProcessor prende un titolo, fa qualche I/O e di elaborazione e le risposte di un Security

val listOfFutures = new ListBuffer[Future[Security]]() 
    var portfolioResponse: Portfolio = _ 
    for (security <- portfolio.getSecurities.toList) { 
    val securityProcessor = actorOf[SecurityProcessor].start() 
    listOfFutures += (securityProcessor ? security) map { 
     _.asInstanceOf[Security] 
    } 
    } 
    val futures = Future.sequence(listOfFutures.toList) 
    futures.map { 
    listOfSecurities => 
     portfolioResponse = MergeHelper.merge(portfolio, listOfSecurities) 
    }.get 

È questo corretta progettazione, e c'è un/modo migliore dispositivo di raffreddamento per implementare questo problema comune con Akka?

Answer 1

val futureResult = Future.sequence(
        portfolio.getSecurities.toList map { security => (actorOf[SecurityProcessor].start() ? security).mapTo[Security] } 
       ) map { securities => MergeHelper.merge(portfolio, securities) }