使用redis作为后端实现的一个持久化、(主要)原子队列(类似于deque或Queue)。
项目描述
- redis_queue对于实现多生产者、
多消费者工作队列很有用。虽然它没有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'
项目详情
关闭
redis_queue-0.5.tar.gz的散列
算法 | 散列摘要 | |
---|---|---|
SHA256 | beccfd48e19e7c0603a7cbdf4bfce23e449470ba2d4a2bc79cfe9733ab0ff842 |
|
MD5 | 786cc7999ba721c6c60b271b2dbec471 |
|
BLAKE2b-256 | 6ff704822d1dd353740d6066481c733691277d2497d08e84fb7431668b7e38d7 |