From 43fc3bf463a23ef7d942de9b57c1658d49e07db2 Mon Sep 17 00:00:00 2001
From: Derek Williams <derek@nebvin.ca>
Date: Wed, 27 Apr 2011 19:39:15 -0600
Subject: [PATCH] Add failing test for Ticket #812

---
 .../src/test/scala/akka/dispatch/FutureSpec.scala      | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala b/akka-actor-tests/src/test/scala/akka/dispatch/FutureSpec.scala
index 7ec397025e..d848eede53 100644
--- 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)
+  }
 }