¿El método Akka onReceive se ejecuta al mismo tiempo?

Question

Aquí está mi escenario:

Tengo un actor principal, que recibe mensajes de múltiples actores secundarios. Estos mensajes contienen datos que se agregarán. En esta lógica de agregación, ¿debo ocuparme de los problemas de sincronización si utilizo una estructura de datos compartida para recopilar la agregación?

else if(arg0 instanceof ReducedMsg){ 

          ReducedMsg reduced = (ReducedMsg)arg0; 
     counter.decrementAndGet(); 

     synchronized(finalResult){ 

      finalResult.add((KeyValue<K, V>) reduced.getReduced()); 

      if(counter.get() == 0){ 
            if(checkAndReduce(finalResult)){ 

        finalResult.clear(); 
       } 
       else{ 
        stop(); 
        latch.countDown(); 
       } 

      } 

     } 



    } 

Así como se puede ver que tengo un finalResult, a la que se agregan cada mensaje, y después de una lógica de procesamiento de la colección debe ser limpiado también.

En realidad, lo que intento implementar es un mapreduce de reducción recursivo (asociativo). Entonces, ¿debo mantener el bloque sincronizado que supongo? ¿O es por casualidad que Akka ejecuta el subproceso onReceive a la vez?

Esta lógica produce resultados precisos y predecibles en pequeños conjuntos de datos. Mi problema es cuando mi conjunto de datos de entrada es un poco grande, el código se cuelga. Quiero estar seguro de que esto se debe a los interruptores de contexto para mi bloque de sincronización, de modo que pueda adoptar un diseño diferente.

Answer 1

onReceive() es nunca llamado concurrentemente. Esta es la garantía más fundamental que Akka te está dando.

Esto significa que si la variable de counter es un campo en un actor y ninguna otra pieza de código puede acceder a que el campo directamente, se puede utilizar con seguridad normales int/long en lugar de AtomicInteger/AtomicLong. Además, la sincronización en finalResult no es necesaria si se trata de un campo encapsulado y oculto en un actor.

Finalmente, el uso de CountDownLatch es sospechoso. En las aplicaciones Akka, no debe usar primitivas de sincronización. Los actores son esencialmente de un solo hilo y todas las comunicaciones (incluidos los datos de activación y transferencia) deben implementarse mediante el envío de mensajes.

esto es todo lo explicado en la documentación: http://doc.akka.io/docs/akka/2.0.2/general/jmm.html#Actors_and_the_Java_Memory_Model