在 Flask 应用程序中使用带有 gunicorn 的多处理

Question

我使用 Gunicorn 和工人类 gevent 制作了一个基本的烧瓶应用程序。我遇到的问题如下。如果我有一个像这样的基本烧瓶应用程序：

from multiprocessing import Pool
import Queue
import random
from threading import Thread
import time

from flask import Flask

app = Flask(__name__)

def f(x):
    return random.randint(1, 6)

def thread_random(queue):
    time.sleep(random.random())
    queue.put(random.randint(1, 6))

def thread_roll():
    q = Queue.Queue()
    threads = []
    for _ in range(3):
        t = Thread(target=thread_random, args=(q, ))
        t.start()
        threads.append(t)
    for t in threads:
        t.join()

    dice_roll = sum([q.get() for _ in range(3)])
    return dice_roll

@app.route('/')
def hello_world():
    # technique 1
    pool = Pool(processes=4)
    return 'roll is: %s \n' % sum(pool.map(f, range(3)))

    # technique 2
    return 'roll is: %s \n' % thread_roll()

if __name__ == '__main__':
    app.run(debug=True)

我采用了两种技术，如果我这样运行，技术 1 会破坏 gunicorn：

sudo gunicorn -b 0.0.0.0:8000 app:app --worker-class gevent

但技术 2 不会。我看到这是因为技术 1 依赖于多处理而技术 2 依赖于线程，但我不明白为什么 gevent 工作人员类不允许池？

Answer 1

如果您使用的是 gevent。您应该尝试使用 monkey_patch。

http://www.gevent.org/gevent.monkey.html