使用redis支持实现的持久(主要是)原子队列(比如deque或queue)。
redis_queue的Python项目详细描述
- redis_queue对于实现多生产者非常有用,
多用户作业队列。虽然它没有所有方便的阻塞和 队列的锁定特性确实具有 多进程安全持久。
- 示例用法:::
>>> from redis import Redis >>> from redis_queue import Queue >>> redis = Redis(host='127.0.0.1', port=6379) >>> queue = Queue(redis, 'test_queue') >>> queue.append('one') >>> queue.append('two') >>> queue.append('three') >>> queue.pop() 'three' >>> queue.pop() 'two' >>> queue.pop() 'one' >>> queue.append('one') >>> queue.append('two') >>> queue.append('three') >>> queue.popleft() 'one' >>> queue.popleft() 'two' >>> queue.popleft() 'three'