aio_parallel_tools.aio_actor.mixins package

Submodules

aio_parallel_tools.aio_actor.mixins.hooks_mixin module

Define all hooks.

class aio_parallel_tools.aio_actor.mixins.hooks_mixin.HooksMixin[source]

Bases: object

Define all hooks.

after_actor_close(task)[source]

Execute after actor close.

after_actor_start()[source]

Execute after actor start.

async after_deal_rev(message, result)[source]

每次处理收到的消息后执行的钩子.

async after_every_loop()[source]

每个循环执行后执行的钩子.

befor_actor_colse()[source]

Execute before actor close.

before_actor_start()[source]

Execute before actor start.

async before_deal_rev(message)[source]

每次处理收到的消息前执行的钩子.

async before_every_loop()[source]

每个循环执行前执行的钩子.

aio_parallel_tools.aio_actor.mixins.id_mixin module

class aio_parallel_tools.aio_actor.mixins.id_mixin.IdentifyMixin[source]

Bases: object

property aid

aio_parallel_tools.aio_actor.mixins.inbox_mixin module

class aio_parallel_tools.aio_actor.mixins.inbox_mixin.InboxMixin(inbox_maxsize=0)[source]

Bases: object

clean_inbox() → List[Any][source]

Clean the Actor’s inbox.

Raises

e – exception unknown

Returns

the rest message not deal with.

Return type

List[Any]

close_accept() → None[source]

Close accept message.

async handle_send_timeout(message)[source]
property inbox

The Actor’s message box.

property inbox_maxsize
property inbox_size
pause() → bool[source]
property paused

Check if the Actor is paused.

async send(message, timeout=None) → None[source]

Send a message to the actor.

send_nowait(message) → None[source]

Send a message to the actor

start_accept() → None[source]

aio_parallel_tools.aio_actor.mixins.loop_mixin module

class aio_parallel_tools.aio_actor.mixins.loop_mixin.LoopMixin(loop=None)[source]

Bases: object

property loop

aio_parallel_tools.aio_actor.mixins.manage_mixin module

class aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin[source]

Bases: object

classmethod AvailableScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC][source]
classmethod BestToSendScope(num: int = None) → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC][source]
classmethod Clean()[source]

clean up all not running actors.

classmethod Close(num: int)[source]
classmethod FindById(aid: str)[source]
classmethod NotAvailableScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC][source]
classmethod NotPausedScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC][source]
classmethod NotRunningScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC][source]
classmethod PausedScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC][source]
classmethod Publish(message: Any, timeout=None)[source]
classmethod Restart(num: int)[source]
classmethod RunningScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC][source]
classmethod Send(message: Any, timeout=None)[source]
classmethod SendById(aid: str, message: Any, timeout=None)[source]
classmethod SendRandom(message: Any, timeout=None)[source]
classmethod Start(num: int, inbox_maxsize=0, loop=None, rev_timeout=None)[source]
remove()[source]

aio_parallel_tools.aio_actor.mixins.task_mixin module

class aio_parallel_tools.aio_actor.mixins.task_mixin.TaskMixin(rev_timeout: int)[source]

Bases: object

async close_task()[source]
async handle_rev_timeout()[source]
property running
start_task()[source]
property task
task_done_callback(fut)[source]

Module contents