+ jRt^RIHt^RIHtHt^RIHtHt^RI H t ^RI H t ^RI Ht!RR]4t]P t] !]4!R R 44tR R ltR #)z> Implementation of an in-memory worker that defers execution. ) annotations)Enumauto)CallableLiteral) implementer)Quit)IExclusiveWorkerc$]tRt^t]!4tRtR#)NoMoreN)__name__ __module__ __qualname____firstlineno__rWork__static_attributes__r :/usr/lib/python3/dist-packages/twisted/_threads/_memory.pyr r s 6Drr cD]tRt^tRt]3RRlltRRltRRltRt R #) MemoryWorkerzl An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} c V^8dQhRRRR/#)pendingz?Callable[[], list[Callable[[], object] | Literal[NoMore.Work]]]returnNoner )formats"r __annotate__MemoryWorker.__annotate__$s""P" "rc <\4VnV!4VnR#)z Create a L{MemoryWorker}. N)r_quit_pending)selfrs&&r__init__MemoryWorker.__init__$sV   rc V^8dQhRRRR/#)rworkzCallable[[], object]rrr )rs"rrr.s##+##rc pVPP4VPPV4R#)ze Queue some work for to perform later; see L{createMemoryWorker}. @param work: The work to perform. N)r checkr!append)r"r&s&&rdoMemoryWorker.do.s&  T"rcV^8dQhRR/#)rrrr )rs"rrr7s))d)rc xVPP4VPP\4R#)z Quit this worker. N)r setr!r) NoMoreWork)r"s&rquitMemoryWorker.quit7s$  Z(r)r!r N) r rrr__doc__listr#r*r0rr rrrrs"TX"#))rrcV^8dQhRR/#)rrz'tuple[MemoryWorker, Callable[[], bool]]r )rs"rrr?sCrc2aRV3Rllp\4oSV3#)z Create an L{IWorker} that does nothing but defer work, to be performed later. @return: a worker that will enqueue work to perform later, and a callable that will perform one element of that work. cV^8dQhRR/#)rrboolr )rs"rr(createMemoryWorker..__annotate__HsTrc<SP'gR#SP^,pV\JdR#SPP^4V!4R#)FT)r!r/pop)peekworkers rperform#createMemoryWorker..performHsBq! : A r)r)r=r<s @rcreateMemoryWorkerr??s!^F G rN)r2 __future__renumrrtypingrrzope.interfacer _conveniencer _ithreadsr r rr/rr?r rrrFsZ #$&'T[[   ) ) )Fr