voussoir/voussoirkit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Make the job's thread private and toss it after it's done.

Browse source
This commit is contained in:
Ethan Dalool 2020-02-12 17:30:23 -08:00
parent b7a2c3b19b
commit 7de2833df9
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
voussoirkit/threadpool.py
View file

@ -157,7 +157,7 @@ class Job:
self.kwargs = kwargs self.kwargs = kwargs
self.value = NO_RETURN self.value = NO_RETURN
self.exception = NO_EXCEPTION self.exception = NO_EXCEPTION
self.thread = None self._thread = None
# joinme_lock works because it is possible for a single thread to block # joinme_lock works because it is possible for a single thread to block
# itself by calling `lock.acquire()` twice. The first call is here, # itself by calling `lock.acquire()` twice. The first call is here,
@ -193,10 +193,11 @@ class Job:
# print(exc) # print(exc)
self.exception = exc self.exception = exc
self.status = RAISED self.status = RAISED
self._thread = None
self.pool._job_finished() self.pool._job_finished()
self.joinme_lock.release() self.joinme_lock.release()
self.status = RUNNING self.status = RUNNING
self.thread = threading.Thread(target=do_it) self._thread = threading.Thread(target=do_it)
self.thread.daemon = True self._thread.daemon = True
self.thread.start() self._thread.start()