Il metodo Akka onReceive viene eseguito contemporaneamente?

Question

Ecco il mio scenario:

Ho un attore principale, che riceve messaggi da più attori secondari. Questi messaggi contengono dati da aggregare. In questa logica di aggregazione, devo occuparmi dei problemi di sincronizzazione, se utilizzo una struttura dati condivisa per raccogliere l'aggregazione?

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(); 
       } 

      } 

     } 



    } 

Quindi, come potete vedere ho una finalResult, a cui verranno aggregati ogni messaggio, e dopo una logica di elaborazione della collezione deve essere cancellato pure.

In realtà quello che sto cercando di implementare è una riduzione della mappa riduttiva (associativa). Quindi ho bisogno di mantenere il blocco sincronizzato presumo? O è per caso Akka esegue l'onReceive un thread alla volta?

Questa logica produce risultati precisi e prevedibili su un piccolo set di dati. Il mio problema è quando il mio set di dati di input è un po 'grande, il codice si blocca. Voglio essere sicuro che sia a causa degli switch di contesto per il mio blocco di sincronizzazione, in modo che possa dwelve in un design diverso.

Answer 1

onReceive() è mai chiamato contemporaneamente. Questa è la garanzia fondamentale che Akka ti sta dando.

Questo significa che se la variabile counter è un campo in un attore e nessun altro pezzo di codice può accedere direttamente a quel campo, è possibile utilizzare in modo sicuro normale int/long invece di AtomicInteger/AtomicLong. Inoltre la sincronizzazione su finalResult non è necessaria presupponendo che si tratti di un campo incapsulato e nascosto in un attore.

Infine l'utilizzo di CountDownLatch è sospetto. Nelle applicazioni Akka non si dovrebbero usare primitive di sincronizzazione. Gli attori sono essenzialmente single-threaded e tutte le comunicazioni (incluso il risveglio e il passaggio dei dati) dovrebbero essere implementate tramite il passaggio dei messaggi.

questo è spiegato nella documentazione: http://doc.akka.io/docs/akka/2.0.2/general/jmm.html#Actors_and_the_Java_Memory_Model