delayqueue
Synchronized delay queue class.
The sole content of this package is a thread-safe
DelayQueue class, which is designed to be as lightweight
as possible. Only the core functionality of the delay queue
itself is included so that custom functionality can be
built around it.
The design closely resembles the built-in Python Queue (queue in Python 3) without some non-critical features that can be added if needed in client code and features marked as likely to be deprecated.
Usage
from delayqueue import DelayQueue
import time
queue = DelayQueue()
queue.put('eggs', delay=30)
print(queue.ask())
# 29.999
try:
item = queue.get()
except NotReady:
print('not ready')
# 'not ready'
time.sleep(30)
except Empty:
print('empty')
# no output: queue was not empty, so not executed
else:
print(item)
# no output: never made it to this block
# try again after sleeping
try:
item = queue.get()
except NotReady:
print('not ready')
# no output: queue was ready after sleeping
time.sleep(30)
except Empty:
print('empty')
# no output: queue wasn't empty
else:
print(item)
# 'eggs'
