pipert.core.utlis

Submodules

• pipert.core.utlis.queue_handler

Package Contents

Classes

QueueHandler

class pipert.core.utlis.QueueHandler(q)

get(self, block=True, timeout=None)

Works just like the get method of queue.Queue

Returns:

item from the queue

timeout_get(self, timeout)

If timeout is reached, forces a context switch using time.sleep(0) and then returns None Args:

timeout: number of seconds until timeout

Returns:

item from the queue

non_blocking_get(self)

If the queue is empty, forces a context switch using time.sleep(0) and then returns None

put(self, item, block=True, timeout=None)

Works just like the put method of queue.Queue

timeout_put(self, item, timeout)

If timeout is reached returns False, else puts item in queue and returns True Args:

item: item to put in queue timeout: number of seconds until timeout

Returns:

True if successful, False if not

non_blocking_put(self, item)

If queue is full, returns False, else puts item in queue and returns True Args:

item: item to put in queue

Returns:

True if successful, False if not

deque_timeout_put(self, item, timeout)

If timeout is reached, it tries to take an item from the queue and then puts the item in the queue. Args:

item: item to put in queue timeout: number of seconds until timeout

Returns:

True if successful, False if had to deque an item

deque_non_blocking_put(self, item)

If queue is full, it tries to take an item from the queue and then puts the item in the queue. Args:

item: item to put in queue

Returns:

True if successful, False if had to deque an item