summaryrefslogtreecommitdiff
path: root/taskflow/tests/unit/test_utils_threading_utils.py
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@yahoo-inc.com>2015-06-18 15:48:11 -0700
committerJoshua Harlow <harlowja@gmail.com>2015-06-21 09:39:12 -0700
commit543cf78a6f26fe4929b53a7bfb9cbdc5f2624fbd (patch)
treeaf972ea24abcbd9c2ccbbad011a57dd230a419f3 /taskflow/tests/unit/test_utils_threading_utils.py
parentcaf37be3456dd3a0a03624afc8c25bcd20459e02 (diff)
downloadtaskflow-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.py12
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)