~@;jTddlmZddlmZddlmZeGddZdS))deque)Logger) singletonc*eZdZdZdZdZdZdZdS)ActorSchedulerzMessage queue for run generator func as thread. Sample: sched = ActorScheduler() sched.new_actor("jab", win32utils.setup_msg_pump()) sched.run() cbi|_t|_td|_dS)Npyjab)actorsr msg_queuerlogger)selfs iC:\Users\Administrator\AppData\Local\Temp\2\pip-target-b0z114gj\lib\python\pyjab/common/actorscheduler.py__init__zActorScheduler.__init__s% Woo c|jd|d|j|df||j|<dS)zQ Admit a newly started actor to the scheduler and give it a name zmsg queue append new actor ''N)r debugr appendr )r nameactors r new_actorzActorScheduler.new_actorsR @@@@AAA udm,,,! Drc|j|x}r?|jd|d|d|j||fdSdS)z1 Send a message to a named actor z send msg 'z ' to actor 'rN)r getr rr r)r rmsgrs rsendzActorScheduler.sendssKOOD)) )5 0 K  D3DDEDDD E E E N ! !5#, / / / / / 0 0rc"|jr|j\}} |jd|d|d||n*#t $r|jdYnwxYw|jdSdS)z< Run as long as there are pending messages. z run actor 'z ' with msg 'rzstop run action in schedulerN)r popleftr rr StopIteration)r rrs rrunzActorScheduler.run&sn B//11JE3 B !!"I"I"I3"I"I"IJJJ 3  B B B !!"@AAAAA B n B B B B Bs6A$BBN)__name__ __module__ __qualname____doc__rrrrrrrrs_&&& """000 B B B B BrrN) collectionsrpyjab.common.loggerrpyjab.common.singletonrrr$rrr(s&&&&&&,,,,,, )B)B)B)B)B)B)B )B)B)Br