simple_queue

Simplified queues

class SimpleToroQueue(io_loop=None)

Bases: object

Simplified Toro queue without size limit

empty()

Return True if the queue is empty, False otherwise

get_all()

Remove ans return all items from the queue, without blocking

get_nowait()

Remove and return an item from the queue without blocking.

Return an item if one is immediately available, else raise queue.Empty.

get_wait(deadline=None)

Remove and return an item from the queue. Returns a Future.

The Future blocks until an item is available, or raises toro.Timeout.

Parameters:deadline – Optional timeout, either an absolute timestamp (as returned by io_loop.time()) or a

datetime.timedelta for a deadline relative to the current time.

put(item)

Put an item into the queue (without waiting)

Parameters:item – item to add

qsize()

Return number of items in the queue

class ThreadSafeQueue

Bases: object

Simplified thread-safe/coroutine queue, without size limit

get()

Pop one item from the queue, without waiting

get_all()

Pop all items from the queue, without waiting

get_wait(deadline=None)

Wait for an available item and pop it from the queue

Parameters:deadline – optional deadline

put(item)

Put an item on the queue

Parameters:item – item

TimeoutTask(func, deadline=None, *args, **kwargs)

Encapsulate a Tornado Task with a deadline