Add failing test for Ticket #812

2011-04-27 19:39:15 -06:00 · 2011-04-27 19:39:15 -06:00 · 43fc3bf463
commit 43fc3bf463
parent 43ebe61ab2
1 changed files with 10 additions and 0 deletions
--- a/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
+++ b/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
@ -375,4 +375,14 @@ class FutureSpec extends JUnitSuite {
    assert(dataflowVar2() === 5)
    assert(dataflowVar.get === 5)
  }
+
+  @Test def ticket812FutureDispatchCleanup {
+    val dispatcher = implicitly[MessageDispatcher]
+    assert(dispatcher.futureQueueSize === 0)
+    val future = Future({Thread.sleep(100);"Done"}, 10)
+    intercept[FutureTimeoutException] { future.await }
+    assert(dispatcher.futureQueueSize === 1)
+    Thread.sleep(200)
+    assert(dispatcher.futureQueueSize === 0)
+  }
 }