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

基类：object

Define all hooks.

after_actor_close(task)

Execute after actor close.

after_actor_start()

Execute after actor start.

async after_deal_rev(message, result)

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

async after_every_loop()

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

befor_actor_colse()

Execute before actor close.

before_actor_start()

Execute before actor start.

async before_deal_rev(message)

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

async before_every_loop()

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

aio_parallel_tools.aio_actor.mixins.id_mixin module

class aio_parallel_tools.aio_actor.mixins.id_mixin.IdentifyMixin

基类：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)

基类：object

clean_inbox() → List[Any]

Clean the Actor's inbox.

引发

e -- exception unknown

返回

the rest message not deal with.

返回类型

List[Any]

close_accept() → None

Close accept message.

async handle_send_timeout(message)

property inbox

The Actor's message box.

property inbox_maxsize

property inbox_size

pause() → bool

property paused

Check if the Actor is paused.

async send(message, timeout=None) → None

Send a message to the actor.

send_nowait(message) → None

Send a message to the actor

start_accept() → None

aio_parallel_tools.aio_actor.mixins.loop_mixin module

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

基类：object

property loop

aio_parallel_tools.aio_actor.mixins.manage_mixin module

class aio_parallel_tools.aio_actor.mixins.manage_mixin.ManageMixin

基类：object

classmethod AvailableScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC]

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

classmethod Clean()

clean up all not running actors.

classmethod Close(num: int)

classmethod FindById(aid: str)

classmethod NotAvailableScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC]

classmethod NotPausedScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC]

classmethod NotRunningScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC]

classmethod PausedScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC]

classmethod Publish(message: Any, timeout=None)

classmethod Restart(num: int)

classmethod RunningScope() → List[aio_parallel_tools.aio_actor.actor_abc.ActorABC]

classmethod Send(message: Any, timeout=None)

classmethod SendById(aid: str, message: Any, timeout=None)

classmethod SendRandom(message: Any, timeout=None)

classmethod Start(num: int, inbox_maxsize=0, loop=None, rev_timeout=None)

remove()

aio_parallel_tools.aio_actor.mixins.task_mixin module

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

基类：object

async close_task()

async handle_rev_timeout()

property running

start_task()

property task

task_done_callback(fut)

Module contents