ProcessPoolExecutor executor manager thread crashes if task fails in some circumstances
オープン
@gpshead がすでに取り組んでいます。
2026年7月3日 から。
3.13
3.14
stdlib
topic-multiprocessing
type-bug
- 主要言語
- Python
- スター
- 77.2k
- フォーク
- 36k
- PR マージ指標
- PR 指標を取得中
説明
Bug report
Bug description:
import time
from concurrent.futures import ProcessPoolExecutor
def fail():
time.sleep(1)
raise ValueError()
executor = ProcessPoolExecutor(max_workers=1, max_tasks_per_child=1)
try:
print(executor.submit(fail).exception() is not None)
finally:
executor.shutdown(wait=False)
If you run this, then the following is printed to the console:
Exception in thread Thread-1:
Traceback (most recent call last):
File "python3.11/threading.py", line 1045, in _bootstrap_inner
self.run()
File "python3.11/concurrent/futures/process.py", line 364, in run
executor._adjust_process_count()
File "python3.11/concurrent/futures/process.py", line 759, in _adjust_process_count
process_count = len(self._processes)
^^^^^^^^^^^^^^^^^^^^
TypeError: object of type 'NoneType' has no len()
If you change the code to using wait=True, or remove the max_tasks_per_child=1 option then the message is not printed.
Probably the fix is just to check if self.processes is None before accessing it at https://github.com/python/cpython/blob/main/Lib/concurrent/futures/process.py#L762
CPython versions tested on:
3.11
Operating systems tested on:
Linux
Linked PRs
- gh-152978
- gh-153363
- gh-154873
コントリビューションガイド
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
評価
この issue はまだ評価されていません。