Esperar a que salga un actor()

Question

¿Cómo espero a que salga Scala Actor()? Configuré dos actores en una prueba unitaria y envío algunos mensajes para que comiencen. Envían algunos mensajes hacia adelante y hacia atrás y, finalmente, ambos llaman a exit(). ¿Cómo hago para que mi prueba unitaria espere que ambos actores terminen antes de aprobar?

Answer 1

Si conoce de antemano la cantidad de mensajes intercambiados entre los actores, puede usar un java.util.concurrent.CountDownLatch para realizar un seguimiento del recuento de mensajes. En los actores, después de cada proceso del mensaje, haga

latch.countDown() 

y en su hilo principal hacer

latch.await() 

Esto hará que su espera hilo principal hasta que el recuento del pestillo se ha reducido a cero.

Si no conoce el conteo de los mensajes por adelantado, pero tiene una condición que indica el final, entonces puede usar java.util.concurrent.locks.Condition. En los actores, cuando su condición se cumple, hacer

if (conditionSatisfied) 
    condition.signal() 

y en su hilo principal hacer

while (!conditionSatisfied) 
condition.await() 

para hacerla esperar hasta que la condición se cumple. Para obtener más información, consulte los javadocs de CountDownLatch y Condition.

Véase this Gist por ejemplo de usar Condition.

Answer 2

En Especificaciones puede usar Eventually Matchers. Si conoce el estado final de su actor o cualquier entidad (por ejemplo, la persistencia de la tienda) se modifica, es posible forzar prueba que esperar hasta que se produzca el cambio a este estado:

<entity state> must eventually(10, 1.second)(be(<state>)) // there will be 10 retires every second, and if the state will be different, exception is thrown