summaryrefslogtreecommitdiff
path: root/tests/tpool_test.py
diff options
context:
space:
mode:
Diffstat (limited to 'tests/tpool_test.py')
-rw-r--r--tests/tpool_test.py18
1 files changed, 17 insertions, 1 deletions
diff --git a/tests/tpool_test.py b/tests/tpool_test.py
index 5af1a40..818bb45 100644
--- a/tests/tpool_test.py
+++ b/tests/tpool_test.py
@@ -20,7 +20,7 @@ import re
import time
import eventlet
-from eventlet import tpool
+from eventlet import tpool, debug, event
from eventlet.support import six
from tests import LimitedTestCase, skipped, skip_with_pyevent, main
@@ -229,6 +229,22 @@ class TestTpool(LimitedTestCase):
tpool.setup()
@skip_with_pyevent
+ def test_killall_remaining_results(self):
+ semaphore = event.Event()
+
+ def native_fun():
+ time.sleep(.5)
+
+ def gt_fun():
+ semaphore.send(None)
+ tpool.execute(native_fun)
+
+ gt = eventlet.spawn(gt_fun)
+ semaphore.wait()
+ tpool.killall()
+ gt.wait()
+
+ @skip_with_pyevent
def test_autowrap(self):
x = tpool.Proxy({'a': 1, 'b': 2}, autowrap=(int,))
assert isinstance(x.get('a'), tpool.Proxy)