Skip to content

Commit 07da591

Browse files
committed
remove if-branch in
1 parent 0ed9a0f commit 07da591

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

Lib/multiprocessing/pool.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -726,10 +726,11 @@ def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool, change_notifier,
726726

727727
task_handler._state = TERMINATE
728728
# Release all semaphores to wake up task_handler to stop.
729-
for job_id in tuple(taskqueue_buffersize_semaphores.keys()):
730-
sema = taskqueue_buffersize_semaphores.pop(job_id, None)
731-
if sema is not None:
732-
sema.release()
729+
for job_id, buffersize_sema in tuple(
730+
taskqueue_buffersize_semaphores.items()
731+
):
732+
buffersize_sema.release()
733+
taskqueue_buffersize_semaphores.pop(job_id, None)
733734

734735
util.debug('helping task handler/workers to finish')
735736
cls._help_stuff_finish(inqueue, task_handler, len(pool))

0 commit comments

Comments
 (0)