Python 怎么优雅的做个 queue worker

[cevincheung]

利用 python 做了个队列消费者（器） 伪代码：

while True:
    job = beanstalk.watch('test')
    body = job.body
    if (body.type == 'sms'):
        sendsms(body.params,job)
    elif (body.type == 'email'):
        sendemail(body.params,job)

怎么可以更优雅的让他动态 fork 出另外一个线程去执行，而让这个 worker 的主入口继续获取别的队列内容。

[Lax]

while job = beanstalk.watch('test'):
fork do
blablabla...

any way, fork 出来的是进程

[NoAnyLove]

concurrent.future

话说，你到底想要在线程中执行还是进程中执行啊？ fork 不是用来创建新进程的吗？

[cevincheung]

@NoAnyLove #2 描述有点问题，总之目标就是建立一个队列内容获取的东西，一旦获取就赶紧丢给真正执行这个队列的负责 [人] ，然后继续获取其他队列中数据。

[wuhang89]

都用队列了，多开几个进程呗，上层拿一个 supervisor 做个守护进程好了，搞那么麻烦干嘛。

[keakon]

理论上性能最好的方式是设置 SO_REUSEPORT，每个进程都去监听 beanstalk 的端口即可。不过需要手动改下客户端源码。

[keakon]

想错了，又不是服务端，SO_REUSEPORT 都不用设置，直接多进程消费即可。

[laike9m]

https://github.com/coleifer/huey
不谢

[yylucifer]

我擦，和我以前写过的消息队列居然是一样的，我也用的 beanstalk。。

这个可以写得很复杂，简单点就做个反射调用就可以了。。