summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
0c64115)
Signed-off-by: Torsten Werner <twerner@debian.org>
# Tell all the threads to quit
self.__resizeLock.acquire()
try:
# Tell all the threads to quit
self.__resizeLock.acquire()
try:
- self.__setThreadCountNolock(0)
- self.__isJoining = True
-
# Wait until all threads have exited
if waitForThreads:
# Wait until all threads have exited
if waitForThreads:
+ for t in self.__threads:
+ t.goAway()
for t in self.__threads:
t.join()
del t
for t in self.__threads:
t.join()
del t
+ self.__setThreadCountNolock(0)
+ self.__isJoining = True
# Reset the pool for potential reuse
self.__isJoining = False
# Reset the pool for potential reuse
self.__isJoining = False