郁闷了有半天了，不想多说了
#! usr/bin/env python
#encoding=utf8
from dreque import Dreque, DrequeWorker
import time
a=Dreque("127.0.0.1", db=None)
a=Dreque(("127.0.0.1",6379),db=10)
a.redis.flushdb()
def some_job(argument):
time.sleep(1)
print argument
for i in xrange(100):
a.enqueue("queue", some_job, argument=i)
print "done!"
worker = DrequeWorker(["queue"],("127.0.0.1",6379),db=10)
worker.work()
相关文章：
-
2022-12-23
-
2022-12-23
-
2022-12-23
-
2021-04-06
-
2021-07-08
-
2021-12-04
-
2021-06-10
-
2021-09-18
猜你喜欢
-
2022-01-20
-
2022-02-24
-
2021-12-03
-
2022-12-23
-
2022-12-23
相关资源
-
下载
2023-02-14
-
下载
2023-01-03
-
下载
2023-01-07