Index
A
|
B
|
C
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
P
|
Q
|
R
|
S
|
T
|
W
A
ActorABC (class in aio_parallel_tools.aio_actor.actor_abc)
ActorManagerRegister (class in aio_parallel_tools.aio_actor.actor_manager)
after_actor_close() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
after_actor_start() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
after_deal_rev() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
after_every_loop() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
aid() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.mixins.id_mixin.IdentifyMixin property)
aio_parallel_tools.aio_actor.actor_abc (module)
aio_parallel_tools.aio_actor.actor_basic (module)
aio_parallel_tools.aio_actor.actor_manager (module)
aio_parallel_tools.aio_actor.mixins (module)
aio_parallel_tools.aio_actor.mixins.hooks_mixin (module)
aio_parallel_tools.aio_actor.mixins.id_mixin (module)
aio_parallel_tools.aio_actor.mixins.inbox_mixin (module)
aio_parallel_tools.aio_actor.mixins.loop_mixin (module)
aio_parallel_tools.aio_actor.mixins.manage_mixin (module)
aio_parallel_tools.aio_actor.mixins.task_mixin (module)
aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_lifo (module)
aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_priority (module)
aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_simple (module)
aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_lifo (module)
aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_priority (module)
aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_simple (module)
aio_parallel_tools.aio_task_pool.core.mixins (module)
aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin (module)
aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin (module)
aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin (module)
aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin (module)
aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin (module)
aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin (module)
aio_parallel_tools.aio_task_pool.core.task_pool_abc (module)
AioActor (class in aio_parallel_tools.aio_actor.actor_basic)
AioAutoScaleTaskPoolLifo (class in aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_lifo)
AioAutoScaleTaskPoolPriority (class in aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_priority)
AioAutoScaleTaskPoolSimple (class in aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_simple)
AioFixedTaskPoolLifo (class in aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_lifo)
AioFixedTaskPoolPriority (class in aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_priority)
AioFixedTaskPoolSimple (class in aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_simple)
AioTaskPoolABC (class in aio_parallel_tools.aio_task_pool.core.task_pool_abc)
AutoScaleWorkerManagerMixin (class in aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin)
available() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.actor_basic.AioActor property)
AvailableScope() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
B
befor_actor_colse() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
before_actor_start() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
before_deal_rev() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
before_every_loop() (aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin method)
BestToSendScope() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
C
Clean() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
clean_inbox() (aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin method)
Close() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
close() (aio_parallel_tools.aio_actor.actor_abc.ActorABC method)
(aio_parallel_tools.aio_actor.actor_basic.AioActor method)
Close() (aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
close() (aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_lifo.AioAutoScaleTaskPoolLifo method)
(aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_priority.AioAutoScaleTaskPoolPriority method)
(aio_parallel_tools.aio_task_pool.aio_autoscale_task_pool_simple.AioAutoScaleTaskPoolSimple method)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC method)
close_accept() (aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin method)
close_auto_scale_worker() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
close_nowait() (aio_parallel_tools.aio_actor.actor_basic.AioActor method)
close_pool() (aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin method)
close_pool_nowait() (aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin method)
close_task() (aio_parallel_tools.aio_actor.mixins.task_mixin.TaskMixin method)
close_workers() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin.FixedWorkerManagerMixin method)
close_workers_hard() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin.FixedWorkerManagerMixin method)
close_workers_nowait_soft() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin.FixedWorkerManagerMixin method)
closed() (aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin property)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC property)
F
FindById() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
FixedWorkerManagerMixin (class in aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin)
G
get_actor() (in module aio_parallel_tools.aio_actor.actor_manager)
H
handle_rev_timeout() (aio_parallel_tools.aio_actor.mixins.task_mixin.TaskMixin method)
handle_send_timeout() (aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin method)
has_actor() (in module aio_parallel_tools.aio_actor.actor_manager)
HooksMixin (class in aio_parallel_tools.aio_actor.mixins.hooks_mixin)
I
IdentifyMixin (class in aio_parallel_tools.aio_actor.mixins.id_mixin)
inbox() (aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin property)
inbox_maxsize() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin property)
inbox_size() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin property)
InboxMixin (class in aio_parallel_tools.aio_actor.mixins.inbox_mixin)
L
LifoQMixin (class in aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin)
loop() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.mixins.loop_mixin.LoopMixin property)
LoopMixin (class in aio_parallel_tools.aio_actor.mixins.loop_mixin)
M
make_close_signal() (aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin.LifoQMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityQMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin.SimpleQMixin method)
make_message() (aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin.LifoQMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityQMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin.SimpleQMixin method)
ManageMixin (class in aio_parallel_tools.aio_actor.mixins.manage_mixin)
max_tasks_number() (aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin.LifoQMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityQMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin.SimpleQMixin property)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC property)
Members (aio_parallel_tools.aio_actor.actor_basic.AioActor attribute)
N
NotAvailableScope() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
NotPausedScope() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
NotRunningScope() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
P
parser_message() (aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin.LifoQMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityQMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin.SimpleQMixin method)
pause() (aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin method)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC method)
paused() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin property)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC property)
PausedScope() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
PriorityQMixin (class in aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin)
PriorityTask (class in aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin)
Publish() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
Q
queue() (aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin.LifoQMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityQMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin.SimpleQMixin property)
R
receive() (aio_parallel_tools.aio_actor.actor_abc.ActorABC method)
remove() (aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin method)
Restart() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
running() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.mixins.task_mixin.TaskMixin property)
RunningScope() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
S
scale() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin.FixedWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC method)
scale_nowait() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin.FixedWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC method)
Send() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
send() (aio_parallel_tools.aio_actor.actor_abc.ActorABC method)
(aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin method)
Send() (aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
send_nowait() (aio_parallel_tools.aio_actor.actor_abc.ActorABC method)
(aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin method)
SendById() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
SendRandom() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
(aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
SimpleProducerMixin (class in aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin)
SimpleQMixin (class in aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin)
size() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin.FixedWorkerManagerMixin property)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC property)
Start() (aio_parallel_tools.aio_actor.actor_abc.ActorABC class method)
start() (aio_parallel_tools.aio_actor.actor_abc.ActorABC method)
(aio_parallel_tools.aio_actor.actor_basic.AioActor method)
Start() (aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin class method)
start() (aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC method)
start_accept() (aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin method)
start_auto_scale() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
start_task() (aio_parallel_tools.aio_actor.mixins.task_mixin.TaskMixin method)
start_workers() (aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.autoscale_worker_manager_mixin.AutoScaleWorkerManagerMixin method)
(aio_parallel_tools.aio_task_pool.core.mixins.worker_manager_mixin.fix_worker_manager_mixin.FixedWorkerManagerMixin method)
submit() (aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_priority.AioFixedTaskPoolPriority method)
(aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin method)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC method)
submit_nowait() (aio_parallel_tools.aio_task_pool.aio_fixed_task_pool_priority.AioFixedTaskPoolPriority method)
(aio_parallel_tools.aio_task_pool.core.mixins.producer_mixin.simple_producer_mixin.SimpleProducerMixin method)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC method)
T
task() (aio_parallel_tools.aio_actor.actor_abc.ActorABC property)
(aio_parallel_tools.aio_actor.mixins.task_mixin.TaskMixin property)
task_done_callback() (aio_parallel_tools.aio_actor.mixins.task_mixin.TaskMixin method)
TaskMixin (class in aio_parallel_tools.aio_actor.mixins.task_mixin)
W
waiting_tasks_number() (aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.lifoq_mixin.LifoQMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.priorityq_mixin.PriorityQMixin property)
(aio_parallel_tools.aio_task_pool.core.mixins.queue_mixin.simpleq_mixin.SimpleQMixin property)
(aio_parallel_tools.aio_task_pool.core.task_pool_abc.AioTaskPoolABC property)
aio_parallel_tools
Tools for develope asynchronous script easily.
Navigation
Task Pool
Kinds of task pool
How to use
Operations
Actor and it’s Manager
How to use
Modules
aio_parallel_tools.aio_task_pool package
Async autoscale task pool with lifo queue
Async autoscale task pool with priority queue
Async autoscale task pool with default queue
Async fixed task pool with lifo queue
Async fixed task pool with priority queue
Async fixed task pool with default queue
Task Pool Core API
Interface
Mixins
aio_parallel_tools.aio_actor package
Actor API
Base Class
Actor Manager
Related Topics
Documentation overview
Quick search