diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2015-06-18 15:48:11 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@gmail.com> | 2015-06-21 09:39:12 -0700 |
| commit | 543cf78a6f26fe4929b53a7bfb9cbdc5f2624fbd (patch) | |
| tree | af972ea24abcbd9c2ccbbad011a57dd230a419f3 /taskflow/tests/unit/test_utils_threading_utils.py | |
| parent | caf37be3456dd3a0a03624afc8c25bcd20459e02 (diff) | |
| download | taskflow-543cf78a6f26fe4929b53a7bfb9cbdc5f2624fbd.tar.gz | |
Remove 2.6 classifier + 2.6 compatibility code
Fixes bug 1445827
Depends-On: I02e3c9aacef0b295a2f823a5cbaf11768a90cb82
Change-Id: I1db681803598ac1bc917fd74a99458bc61edf3f1
Diffstat (limited to 'taskflow/tests/unit/test_utils_threading_utils.py')
| -rw-r--r-- | taskflow/tests/unit/test_utils_threading_utils.py | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/taskflow/tests/unit/test_utils_threading_utils.py b/taskflow/tests/unit/test_utils_threading_utils.py index 66ef2d0..f354a98 100644 --- a/taskflow/tests/unit/test_utils_threading_utils.py +++ b/taskflow/tests/unit/test_utils_threading_utils.py @@ -16,6 +16,7 @@ import collections import functools +import threading import time from taskflow import test @@ -28,17 +29,12 @@ def _spinner(death): class TestThreadHelpers(test.TestCase): - def test_event_wait(self): - e = tu.Event() - e.set() - self.assertTrue(e.wait()) - def test_alive_thread_falsey(self): for v in [False, 0, None, ""]: self.assertFalse(tu.is_alive(v)) def test_alive_thread(self): - death = tu.Event() + death = threading.Event() t = tu.daemon_thread(_spinner, death) self.assertFalse(tu.is_alive(t)) t.start() @@ -48,7 +44,7 @@ class TestThreadHelpers(test.TestCase): self.assertFalse(tu.is_alive(t)) def test_daemon_thread(self): - death = tu.Event() + death = threading.Event() t = tu.daemon_thread(_spinner, death) self.assertTrue(t.daemon) @@ -59,7 +55,7 @@ class TestThreadBundle(test.TestCase): def setUp(self): super(TestThreadBundle, self).setUp() self.bundle = tu.ThreadBundle() - self.death = tu.Event() + self.death = threading.Event() self.addCleanup(self.bundle.stop) self.addCleanup(self.death.set) |
