Fastrq - Queue, Stack and Priority Queue built on Redis

Features

• Abstract Queue, Deque, Capped Queue/Deque, and Overflow-able Capped Queue/Deque
• Abstract Stack, Capped Stack
• Abstract Priority Queue, Capped Priority Queue and Overflow-able Capped Priority Queue
• Push and Pop support batch operation
• Using Lua scripts to save RTT (Round Trip Time)

Data types

Queue

• first in and first out
• unlimited capacity
• support batch push and batch pop

Deque

Derive from queue with more features

• support push front and push back
• support pop front and pop back

Capped Queue/Deque

Derive from queue/deque with more features

• Have fixed capacity
• Push to a full one would fail
• Push to one whose positions are not enough would fail

Overflow-able Capped Queue/Deque

Derive from capped queue/deque with more features

• The queue length would never exceed its capacity
• Push to an end would push out from the other end if one is full

Stack

• Last in and First out
• Unlimited capacity
• Support batch push and batch pop

Capped Stack

Derive from Stack with more features

• Have fixed capacity
• Push to a full capped stack would fail
• Push to a capped stack whose positions are not enough would fail

Priority Queue

• The lower the score, the higher the priority
• Unlimited capacity
• Support batch push and batch pop

Capped Priority Queue

Derive from Priority Queue with more features

• Have fixed capacity
• Push to a full one would fail
• Push to a capped one whose positions are not enough would fail

Overflow-able Capped Priority Queue

Derive from Capped Priority Queue with more features

• The queue length would never exceed its capacity
• Push to would push out the lowest priority if queue is full

install

from source

python setup.py install

use pip

pip install fastrq

Usage

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()  # 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()