Flask+Gunicorn环境下全局Popen对象poll()返回值与实际进程状态不符的问题

嘿，这个问题其实是Gunicorn的进程模型在背后搞鬼！让我给你拆解一下：

你现在的代码是在Gunicorn主进程启动前就创建了sleep 999的子进程，然后Gunicorn会fork出worker进程来处理请求。这里的关键是：fork出来的worker进程会继承主进程的内存空间，包括那个MY_PROCESS的Popen对象，但这个对象只是主进程里原对象的副本——它和真实运行的sleep进程之间没有正确的关联了。

当worker进程调用MY_PROCESS.poll()时，它其实是在查询自己进程空间里这个副本记录的状态，而不是去系统里找那个真实的sleep进程。所以才会出现明明sleep还在运行，但poll()却返回0（表示进程已退出）的诡异情况。

解决方案有两种，看你的需求选： #

方案一：在worker进程内部创建子进程

如果你的业务允许每个worker拥有自己的子进程，那最好把创建子进程的逻辑放到worker进程的初始化阶段，比如用Flask的@before_first_request装饰器：

from subprocess import Popen
from flask import Flask, jsonify
import gunicorn.app.base

class MyApp(gunicorn.app.base.BaseApplication):
    def __init__(self, app, options=None):
        self.options = options or {}
        self.application = app
        super().__init__()

    def load_config(self):
        config = {key: value for key, value in self.options.items()
                  if key in self.cfg.settings and value is not None}
        for key, value in config.items():
            self.cfg.set(key.lower(), value)

    def load(self):
        return self.application

app = Flask(__name__)
MY_PROCESS = None

@app.before_first_request
def init_subprocess():
    global MY_PROCESS
    MY_PROCESS = Popen(["sleep", "999"])
    # 打印worker内的进程信息，方便验证
    print({
        "obj": str(MY_PROCESS),
        "pid": MY_PROCESS.pid,
        "poll": MY_PROCESS.poll()
    })

@app.route("/")
def hello():
    """Return some info about our global subprocess"""
    return jsonify({
        "obj": str(MY_PROCESS),
        "pid": MY_PROCESS.pid,
        "poll": MY_PROCESS.poll()
    })

# Launch the app
MyApp(app).run()

这样子进程是worker自己创建的，它能完全掌控这个进程的状态，poll()自然就能正确返回None（运行中）或者退出码了。

方案二：直接查询系统层面的进程状态

如果必须在主进程创建子进程（比如全局只需要一个实例），那别依赖Popen对象的poll()，直接通过PID去系统里查真实状态，用标准库的os.waitpid就行：

import os
from subprocess import Popen
from flask import Flask, jsonify
import gunicorn.app.base

class MyApp(gunicorn.app.base.BaseApplication):
    def __init__(self, app, options=None):
        self.options = options or {}
        self.application = app
        super().__init__()

    def load_config(self):
        config = {key: value for key, value in self.options.items()
                  if key in self.cfg.settings and value is not None}
        for key, value in config.items():
            self.cfg.set(key.lower(), value)

    def load(self):
        return self.application

# 在主进程创建子进程
MY_PROCESS = Popen(["sleep", "999"])

app = Flask(__name__)

@app.route("/")
def hello():
    """Return some info about our global subprocess"""
    poll_result = None
    try:
        # 使用WNOHANG参数，不会阻塞等待进程退出
        pid, status = os.waitpid(MY_PROCESS.pid, os.WNOHANG)
        if pid != 0:
            # 进程已退出，转换为退出码
            poll_result = os.waitstatus_to_exitcode(status)
    except ChildProcessError:
        # 进程不存在或者当前进程无权查询（比如worker进程查主进程的子进程）
        pass

    return jsonify({
        "obj": str(MY_PROCESS),
        "pid": MY_PROCESS.pid,
        "poll": poll_result
    })

# 预览主进程内的信息
print({
    "obj": str(MY_PROCESS),
    "pid": MY_PROCESS.pid,
    "poll": MY_PROCESS.poll()
})

# Launch the app
MyApp(app).run()

这个方法绕开了Popen对象的副本问题，直接和系统交互，拿到的就是真实的进程状态。

总结一下 #

核心问题就是Gunicorn的fork机制导致worker里的Popen对象是“无效副本”，没法正确追踪原进程状态。选哪种方案看你要不要每个worker都有独立子进程，或者全局共用一个。

备注：内容来源于stack exchange，提问作者ajwood