From 8acfb5f528dfb36f6447dd2e876de4f2a1fff27a Mon Sep 17 00:00:00 2001
From: Viktor Klang <viktor.klang@gmail.com>
Date: Thu, 16 Sep 2010 14:28:06 +0200
Subject: [PATCH] Make ExecutorBasedEventDrivenDispatcherActorSpec
 deterministic

---
 .../ExecutorBasedEventDrivenDispatcherActorSpec.scala        | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/akka-actor/src/test/scala/dispatch/ExecutorBasedEventDrivenDispatcherActorSpec.scala b/akka-actor/src/test/scala/dispatch/ExecutorBasedEventDrivenDispatcherActorSpec.scala
index 56d98071d7..3935bc9b0b 100644
--- a/akka-actor/src/test/scala/dispatch/ExecutorBasedEventDrivenDispatcherActorSpec.scala
+++ b/akka-actor/src/test/scala/dispatch/ExecutorBasedEventDrivenDispatcherActorSpec.scala
@@ -110,6 +110,8 @@ class ExecutorBasedEventDrivenDispatcherActorSpec extends JUnitSuite {
    val works   = new AtomicBoolean(true)
    val latch   = new CountDownLatch(1)
    val start   = new CountDownLatch(1)
+   val ready   = new CountDownLatch(1)
+
    val fastOne = actorOf(
                    new Actor {
                      self.dispatcher = throughputDispatcher
@@ -120,7 +122,7 @@ class ExecutorBasedEventDrivenDispatcherActorSpec extends JUnitSuite {
                    new Actor {
                      self.dispatcher = throughputDispatcher
                      def receive = {
-                       case "hogexecutor" => start.await
+                       case "hogexecutor" => ready.countDown; start.await
                        case "ping"        => works.set(false); self.stop
                      }
                    }).start
@@ -128,6 +130,7 @@ class ExecutorBasedEventDrivenDispatcherActorSpec extends JUnitSuite {
    slowOne ! "hogexecutor"
    slowOne ! "ping"
    fastOne ! "ping"
+   assert(ready.await(5,TimeUnit.SECONDS) === true)
    Thread.sleep(deadlineMs)
    start.countDown
    assert(latch.await(10,TimeUnit.SECONDS) === true)