Python 怎么优雅的做个 queue worker

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 的主入口继续获取别的队列内容。

Python

body

job

Worker

8 条回复 • 2017-09-06 19:00:08 +08:00

Lax

2017-09-03 21:27:12 +08:00

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

any way, fork 出来的是进程

NoAnyLove

2017-09-03 23:23:57 +08:00

concurrent.future

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

cevincheung

2017-09-04 03:17:37 +08:00

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

wuhang89

2017-09-04 10:20:54 +08:00

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

keakon

2017-09-04 13:15:51 +08:00

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

keakon

2017-09-04 13:17:53 +08:00

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

laike9m

2017-09-04 14:08:54 +08:00

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

yylucifer

2017-09-06 19:00:08 +08:00

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

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