基于kombu的分布式队列库
queueup的Python项目详细描述
QueueUp-一个简单易用的队列接口，可满足您的所有需求
QueueUp是kombu上的一个完全集成的队列接口，可以将所有设置完全包含在单个对象中。在
我们将kombu和AMQP作为一个整体使用的原因是为了允许复杂的对象和交付保证，我们通常不会在更新的平台上获得。在
与QueueUp和Queue的区别
使用QueueUp库的方式与使用queue.Queue库的方式相同。让我们看看区别。在
python的queue
importtimeimportrandomimportthreadingfromqueueimportQueue# We're starting two threading daemons, # 1. one that pushes information into a queue, # 2. the other that reads information from the queue then publishes itdefqueue_pusher(q):whileTrue:q.put(random.randint(0,1000))time.sleep(0.05)defqueue_reciever(q):whileTrue:qitem=q.get(block=True)print(f"Printing {item}")time.sleep(0.05)if__name__=="__main__":common_queue=Queue()threading.Thread(target=queue_pusher,daemon=True,args=(common_queue,)).start()threading.Thread(target=queue_reciever,daemon=True,args=(common_queue,)).start()# Now the two queues will communicate with each other.whileTrue:time.sleep(5)
一个QueueUp
- 项目
标签：
欢迎加入QQ群-->： 979659372
