Let Job.join accept a timeout.

2021-11-20 18:48:05 -08:00 · 2021-11-20 18:48:05 -08:00 · 039ac45e17
commit 039ac45e17
parent f7250f8157
1 changed files with 2 additions and 2 deletions
--- a/voussoirkit/threadpool.py
+++ b/voussoirkit/threadpool.py
@ -414,8 +414,8 @@ class Job:

        self._done_event.set()

-    def join(self):
+    def join(self, timeout=None):
        '''
        Block until this job runs and completes.
        '''
-        self._done_event.wait()
+        self._done_event.wait(timeout=timeout)