基于 Redis 的队列和堆栈 Fastrq

MIT
Python
跨平台
2018-11-26
solohunter

基于redis的队列、双向队列、优先队列和堆栈,以及众多增强版本

  1. 支持定长。向满队列PUSH会失败,向容量不足的队列PUSH同样会失败。

  2. 支持可溢出。定长队列长度超过容量限制,元素会从另一端溢出。

  3. PUSH/POP支持批量操作

队列类型:

Queue

  • FIFO

Deque

  • 支持从前端/后端PUSH/POP

Capped Queue/Deque

  • 容量固定

  • 向一个满的队列PUSH会失败

  • 向一个容量不足的队列PUSH会失败

Overflow-able Capped Queue/Deque

  • 队列长度超过容量自动溢出

  • 单向队列从前端溢出

  • 双向队列从PUSH端的另一端溢出

Priority Queue

  • 分值越低,优先级越高

Capped Priority Queue

  • 容量固定

Overflow-able Capped Priority Queue

  • 队列长度超过容量自动溢出

  • 溢出顺序按优先级从低到高

Stack

  • LIFO

Capped Stack

  • 容量固定

源码安装

python setup.py install

pip安装

pip install fastrq

使用

from fastrq.queue import Queue, CappedQueue
from fastrq.deque import Deque
from fastrq.stack import Stack
from fastrq.priorityqueue import PriorityQueue

# queue
q = Queue("fastrq_queue")
q.push(1)
q.push([2, 3])
q.ttl(10)   # set the lifetime in seconds
q.range(0, -1)  # got ['1', '2', '3']
q.range(0, 1)  # got ['1', '2']
q.pop()
q.pop(2)
q.destruct() # destruct the queue
cq = CappedQueue("fastrq_capped_queue", 3)
cq.push(1)
cq.push(2)
cq.push([3, 4]) # got "err_qof"
cq.push(3)
cq.push(4) # got "err_qf"
of_cq = OfCappedQueue("fastrq_of_capped_queue", 3)
of_cq.push(1)
of_cq.push([2, 3, 4])  # "1" would be pushed out


# deque
dq = Deque("fastrq_deque")
dq.push_front([1, 2])
dq.push_back([3, 4])
dq.pop_front()
dq.pop_back()

# priority queue
pq = PriorityQueue("fastrq_priority_queue")
pq.push({'alibaba': 1})
pq.push({'google': 0, 'microsoft': 1})
pq.pop()
pq.pop(2)

# stack
s = Stack("fastrq_stack")
s.push([1,2,3])
s.pop()
的码云指数为
超过 的项目
加载中

评论(0)

暂无评论

暂无资讯

暂无问答

暂无博客

返回顶部
顶部