`multiprocessing.Process.is_alive()` can incorrectly return True after `join()`
@gpshead 已经在做这个了。
开始于 2026年1月11日。
- 主要语言
- Python
- 星标
- 77.2k
- 派生
- 35.9k
- PR 合并指标
- PR 指标待抓取
描述
Bug report
Bug description:
This came up in https://github.com/python/cpython/pull/130849#discussion_r1980137089
The problem is that popen_fork.Popen (and popen_spawn.Popen and popen_forkserver.Popen) are not thread-safe:
The first successful call to os.waitpid() may reap the pid so that subsequent calls raise an OSError. I've only seen this on macOS (not Linux). We may not yet however have set self.returncode -- that happens a few statements later, so poll() can return None if:
- The process has finished
- Another thread called poll(), but hasn't yet set
self.returncode
And then is_alive() can return True:
Note that some classes like concurrent.futures.ProcessPoolExecutor use threads internally, so the user may not even know that threads are involved.
Repro:
repro.py
import os
import multiprocessing as mp
import threading
import time
import sys
original_excepthook = threading.excepthook
def on_except(args):
original_excepthook(args)
os._exit(1)
threading.excepthook = on_except
def p1():
pass
def thread1(p):
while p.is_alive():
time.sleep(0.00001)
pass
def test():
for i in range(1000):
print(i)
p = mp.Process(target=p1)
p.start()
t = threading.Thread(target=thread1, args=(p,))
t.start()
p.join()
assert not p.is_alive()
t.join()
def main():
threads = [threading.Thread(target=test) for _ in range(10)]
for t in threads:
t.start()
for t in threads:
t.join()
if __name__ == "__main__":
main()
NOTE:
- This is unrelated to free threading
popen_fork.Popen(and subclasses) are distinct fromsubprocess.Popen
CPython versions tested on:
CPython main branch
Operating systems tested on:
macOS
Linked PRs
- gh-131440
贡献指南
从这里开始
- 先读完整个 Issue,再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库,在一个分支上完成修改。
- 提交 Pull Request,并在描述里引用这个 Issue 编号。
评估
这个 Issue 还没有评估数据。