Jun 29, 2018 · Aug 7, 2019 · Jun 29, 2018 · Aug 5, 2019 · Aug 7, 2019
diff --git a/Lib/multiprocessing/pool.py b/Lib/multiprocessing/pool.py
    @staticmethod
    def _handle_results(outqueue, get, cache):
        thread = threading.current_thread()
        sentinel_counter = 0

        while 1:
            try:

            if task is None:
                util.debug('result handler got sentinel')
                sentinel_counter += 1
                break

            job, i, obj = task

            if task is None:
                util.debug('result handler ignoring extra sentinel')
                sentinel_counter += 1
                continue
            job, i, obj = task
            try:
            # attempts to add the sentinel (None) to outqueue may
            # block.  There is guaranteed to be no more than 2 sentinels.
            try:
 for i in range(10):
 while sentinel_counter < 2:
                    if not outqueue._reader.poll():
                        break
                    get()
                    task = get()
                    if task is None:
                        sentinel_counter += 1
            except (OSError, EOFError):
                pass
Original file line number	Diff line number	Diff line change
Expand Up		@@ -464,6 +464,7 @@ def _handle_tasks(taskqueue, put, outqueue, pool, cache):
		@staticmethod
		def _handle_results(outqueue, get, cache):
		thread = threading.current_thread()
		sentinel_counter = 0

		while 1:
		try:
Expand All		@@ -479,6 +480,7 @@ def _handle_results(outqueue, get, cache):

		if task is None:
		util.debug('result handler got sentinel')
		sentinel_counter += 1
		break

		job, i, obj = task
Expand All		@@ -497,6 +499,7 @@ def _handle_results(outqueue, get, cache):

		if task is None:
		util.debug('result handler ignoring extra sentinel')
		sentinel_counter += 1
Copy link ppperyAug 5, 2019 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. This extra sentinel is no longer ignored, so the debug is wrong. Copy link Author 3mb3dw0rk5Aug 7, 2019 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. Obviously right. Fixed that.
		continue
		job, i, obj = task
		try:
Expand All		@@ -511,10 +514,12 @@ def _handle_results(outqueue, get, cache):
		# attempts to add the sentinel (None) to outqueue may
		# block. There is guaranteed to be no more than 2 sentinels.
		try:
		for i in range(10):
		while sentinel_counter < 2:
		if not outqueue._reader.poll():
		break
		get()
		task = get()
		if task is None:
		sentinel_counter += 1
		except (OSError, EOFError):
		pass

Expand Down