Queues¶

Package queue handlers

class kissats.queues.BaseQues¶

Bases: object

Base class for task management queues

active_que_len¶: length of the active queue

add_to_active_que(task, top=False)¶: add a task to the active queue

clear_active_que()¶: Clear the active queue

clear_all_que()¶: clear all queues

clear_delay_que()¶: Clear the delay queue

delay_que_add_task(task)¶

place task(s) and reservation(s) in delay queue ordered on reservation time

Parameters:	task (Task) – Task to add

delay_que_len¶: length of the delay queue

in_active_que(task)¶

Check if a task is already in the active queue

Parameters:	task (Task) – The task to check

peek_delay()¶: peek at the right side (bottom)

pop_active()¶: pop the next item from the right side (bottom)

popleft_active()¶: pop the next item from the left side (top)

remove_from_active_que(task)¶

remove a task from the active queue

Parameters:	task (object) – task to remove

set_active_que(que_name)¶

Set the active queue

Parameters:	que_name (str) – queue to set active

class kissats.queues.PackQues¶

Bases: kissats.queues.BaseQues

Task manager queues

active_que_len¶: length of the active queue

add_to_active_que(task, top=False)¶: add a task to the active queue

clear_active_que()¶: Clear the active queue

clear_all_que()¶: clear all queues

clear_delay_que()¶: Clear the delay queue