summaryrefslogtreecommitdiff
path: root/taskflow/tests/unit/worker_based
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@gmail.com>2015-01-24 00:45:36 -0800
committerJoshua Harlow <harlowja@gmail.com>2015-01-24 18:33:51 -0800
commitca82e20efe8f5c5d50b3db89be0342710ef7f73b (patch)
treee4682847164001d229d70f1ecc94739fd80958af /taskflow/tests/unit/worker_based
parent1ae7a8e67b79f1ea7533525ef27271978365afe9 (diff)
downloadtaskflow-ca82e20efe8f5c5d50b3db89be0342710ef7f73b.tar.gz
Add a thread bundle helper utility + tests
To make it easier to create a bunch of threads in a single call (and stop them in a single call) create a concept of a thread bundle (similar to a thread group) that will call into a provided set of factories to get a thread, activate callbacks to notify others that a thread is about to start or stop and then perform the start or stop of the bound threads in a orderly manner. Change-Id: I7d233cccb230b716af41243ad27220b988eec14c
Diffstat (limited to 'taskflow/tests/unit/worker_based')
-rw-r--r--taskflow/tests/unit/worker_based/test_executor.py3
1 files changed, 0 insertions, 3 deletions
diff --git a/taskflow/tests/unit/worker_based/test_executor.py b/taskflow/tests/unit/worker_based/test_executor.py
index cdb421d..101031c 100644
--- a/taskflow/tests/unit/worker_based/test_executor.py
+++ b/taskflow/tests/unit/worker_based/test_executor.py
@@ -353,9 +353,6 @@ class TestWorkerTaskExecutor(test.MockTestCase):
ex = self.executor()
ex.start()
- # wait until executor thread is done
- ex._proxy_thread.join()
-
# stop executor
ex.stop()