Queue Mixins

lifoq_mixin module

Submit tasks and Send Signals using Lifo Q.

class aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin.LifoQMixin(queue: Optional[asyncio.queues.Queue] = None, queue_maxsize: int = 0)

Bases: object

Submit tasks and Send Signals using Lifo Q.

Requirement:

loop (Property): Event loop.

Support:

queue(Property): Event loop.

waiting_tasks_number(Property): Task size in queue.

max_tasks_number(Property): Queue’s max size.

make_message (Method): Make task to message.

make_close_signal (Method): Make worker colse signal.

parser_message (Method): Parser messages from queue.

make_close_signal()

Make close signal to send.

make_message(task: aio_parallel_tools.aio_task_pool.core.task.Task, **kwargs)

Make task message to send.

property max_tasks_number

Maximum number of the waiting tasks.

Returns

The maximum number of the waiting tasks.

Return type

int

parser_message(message: Any) → Any

Parser messages from queue.

property queue

Queue for sending and receiving tasks.

property waiting_tasks_number

Now number of the waiting tasks.

Returns

The number of the waiting tasks.

Return type

int

priorityq_mixin module

Submit tasks and Send Signals using Priority Q.

class aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityQMixin(queue: Optional[asyncio.queues.Queue] = None, queue_maxsize: int = 0)

Bases: object

Submit tasks and Send Signals using Priority Q.

Requirement:

loop (Property): event loop.

Support:

queue(Property): Event loop.

waiting_tasks_number(Property): Task size in queue.

max_tasks_number(Property): Queue’s max size.

make_message (Method): Make task to message.

make_close_signal (Method): Make worker colse signal.

parser_message (Method): Parser messages from queue.

make_close_signal()

Make close signal to send.

make_message(task: aio_parallel_tools.aio_task_pool.core.task.Task, **kwargs)

Make task message to send.

property max_tasks_number

Maximum number of the waiting tasks.

Returns

The maximum number of the waiting tasks.

Return type

int

parser_message(message: aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityTask) → Any

Parser messages from queue.

property queue

Queue for sending and receiving tasks.

property waiting_tasks_number

Now number of the waiting tasks.

Returns

The number of the waiting tasks.

Return type

int

class aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityTask(weight: int, task: Any)

Bases: object

Priority Task Message.

simpleq_mixin module

Submit tasks and Send Signals using simple Q.

class aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin.SimpleQMixin(queue: Optional[asyncio.queues.Queue] = None, queue_maxsize: int = 0)

Bases: object

Submit tasks and Send Signals using simple Q.

Requirement:

loop (Property): Event loop.

Support:

queue(Property): Event loop.

waiting_tasks_number(Property): Task size in queue.

max_tasks_number(Property): Queue’s max size.

make_message (Method): Make task to message.

make_close_signal (Method): Make worker colse signal.

parser_message (Method): Parser messages from queue.

make_close_signal()

Make close signal to send.

make_message(task: aio_parallel_tools.aio_task_pool.core.task.Task, **kwargs)

Make task message to send.

property max_tasks_number

Maximum number of the waiting tasks.

Returns

The maximum number of the waiting tasks.

Return type

int

parser_message(message: Any) → Any

Parser messages from queue.

property queue

Queue for sending and receiving tasks.

property waiting_tasks_number

Now number of the waiting tasks.

Returns

The number of the waiting tasks.

Return type

int