Ñò ˜à"Ic@s5ddgZddkZddkZddkZddkZddkZddkZddkZddkl Z l Z ddk Z ddk l Z ddklZlZlZlZddklZlZlZlZddklZdefd „ƒYZeƒZd efd „ƒYZdefd „ƒYZdS( tQueuet SimpleQueueiÿÿÿÿN(tEmptytFull(tPipe(tLocktBoundedSemaphoret Semaphoret Condition(tdebugtinfotFinalizetregister_after_fork(tassert_spawningcBsËeZdd„Zd„Zd„Zd„Zedd„Zedd„Z d„Z d„Z d „Z d „Z d „Zd „Zd „Zd„Zd„Zed„ƒZed„ƒZed„ƒZRS(icCsÆ|djotii}n||_tdtƒ\|_|_tƒ|_ t i ƒ|_ t idjo d|_n tƒ|_t|ƒ|_|iƒt idjot|tiƒndS(Nitduplextwin32(t_multiprocessingtSemLockt SEM_VALUE_MAXt_maxsizeRtFalset_readert_writerRt_rlocktostgetpidt_opidtsystplatformtNonet_wlockRt_semt _after_forkR R(tselftmaxsize((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt__init__ s      cCs8t|ƒ|i|i|i|i|i|i|ifS(N(R RRRRRRR(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt __getstate__2s cCs>|\|_|_|_|_|_|_|_|iƒdS(N(RRRRRRRR (R!tstate((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt __setstate__7s0cCstdƒtitiƒƒ|_tiƒ|_d|_ d|_ t |_ t |_ d|_|ii|_|ii|_|ii|_dS(NsQueue._after_fork()(R t threadingRRt _notemptyt collectionstdequet_bufferRt_threadt _jointhreadRt_joincancelledt_closedt_closeRtsendt_sendRtrecvt_recvtpollt_poll(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR <s      cCs|ii||ƒp t‚n|iiƒz?|idjo|iƒn|ii|ƒ|ii ƒWd|ii ƒXdS(N( RtacquireRR(R,Rt _start_threadR+tappendtnotifytrelease(R!tobjtblockttimeout((s3/mit/python/lib/python2.6/multiprocessing/queues.pytputIs  cCsú|oP|djoC|iiƒz!|iƒ}|iiƒ|SWd|iiƒXn |otiƒ|}n|ii||ƒp t‚nzS|i|o|tiƒpdƒp t‚n|iƒ}|iiƒ|SWd|iiƒXdS(Ng( RRR7R4RR;ttimeRR6(R!R=R>trestdeadline((s3/mit/python/lib/python2.6/multiprocessing/queues.pytgetWs$    (   cCs|i|iiiƒS(N(RRt_semlockt _get_value(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pytqsizeoscCs |iƒ S(N(R6(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pytemptysscCs|iiiƒS(N(RRDt_is_zero(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pytfullvscCs |itƒS(N(RCR(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt get_nowaityscCs|i|tƒS(N(R?R(R!R<((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt put_nowait|scCs2t|_|iiƒ|io|iƒndS(N(tTrueR/RtcloseR0(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyRMs   cCs&tdƒ|io|iƒndS(NsQueue.join_thread()(R R-(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt join_thread…s  cCs>tdƒt|_y|iiƒWntj onXdS(NsQueue.cancel_join_thread()(R RLR.R-tcanceltAttributeError(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pytcancel_join_thread‹s   c Cstdƒ|iiƒtidtid|i|i|i|i |i i fddƒ|_ t |i _tdƒ|i iƒtdƒ|itiƒj}|i o<| o4t|i titi|i ƒgdd ƒ|_nt|ti|i|igdd ƒ|_dS( NsQueue._start_thread()ttargettargstnametQueueFeederThreadsdoing self._thread.start()s... done self._thread.start()t exitpriorityiûÿÿÿi (R R+tclearR'tThreadRt_feedR(R2RRRMR,RLtdaemontstartRRRR.R t_finalize_jointweakreftrefR-t_finalize_closeR0(R!tcreated_by_this_process((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR8“s*           cCsFtdƒ|ƒ}|dj o|iƒtdƒn tdƒdS(Nsjoining queue threads... queue thread joineds... queue thread already dead(R Rtjoin(ttwrtthread((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR\¹s     cCsAtdƒ|iƒz|itƒ|iƒWd|iƒXdS(Nstelling queue thread to quit(R R7R9t _sentinelR:R;(tbuffertnotempty((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR_Ãs    cCstdƒddkl}|i}|i}|i}|i} t} ti djo|i} |i} nd} y¹x²|ƒz|p |ƒnWd|ƒXyqxj| ƒ} | | jotdƒ|ƒdS| djo|| ƒq¤| ƒz|| ƒWd| ƒXq¤Wqvt j oqvXqvWn`t j oT}y5|ƒot d|ƒnddk}|iƒWqŒt j oqŒXnXdS(Ns$starting thread to feed data to pipei(t is_exitingRs%feeder thread got sentinel -- exitingserror in queue thread: %siÿÿÿÿ(R tutilRgR7R;twaittpopleftRdRRRt IndexErrort ExceptionR t tracebackt print_exc(ReRfR1t writelockRMRgtnacquiretnreleasetnwaittbpoplefttsentineltwacquiretwreleaseR<teRm((s3/mit/python/lib/python2.6/multiprocessing/queues.pyRYÍsR              N(t__name__t __module__R#R$R&R RLRR?RCRFRGRIRJRKRMRNRQR8t staticmethodR\R_RY(((s3/mit/python/lib/python2.6/multiprocessing/queues.pyRs$             &  t JoinableQueuecBsGeZdd„Zd„Zd„Zedd„Zd„Zd„Z RS(icCs/ti||ƒtdƒ|_tƒ|_dS(Ni(RR#Rt_unfinished_tasksRt_cond(R!R"((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR#scCsti|ƒ|i|ifS(N(RR$R}R|(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR$scCs.ti||d ƒ|d\|_|_dS(Niþÿÿÿ(RR&R}R|(R!R%((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR&scCs'ti||||ƒ|iiƒdS(N(RR?R|R;(R!titemR=R>((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR?scCsm|iiƒzK|iitƒptdƒ‚n|iiiƒo|iiƒnWd|iiƒXdS(Ns!task_done() called too many times( R}R7R|Rt ValueErrorRDRHt notify_allR;(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt task_done!s cCsJ|iiƒz(|iiiƒp|iiƒnWd|iiƒXdS(N(R}R7R|RDRHRiR;(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyRa+s  N( RxRyR#R$R&RLRR?RRa(((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR{s     cBs5eZd„Zd„Zd„Zd„Zd„ZRS(cCs^tdtƒ\|_|_tƒ|_tidjo d|_ n tƒ|_ |i ƒdS(NRR( RRRRRRRRRRt _make_methods(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR#9s    cCs|iiƒ S(N(RR5(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyRGBscCs&t|ƒ|i|i|i|ifS(N(R RRRR(R!((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR$Es cCs,|\|_|_|_|_|iƒdS(N(RRRRR‚(R!R%((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR&Iscs­|ii‰|ii|ii‰‰‡‡‡fd†}||_|idjo|ii |_ nD|ii ‰|ii|ii‰‰‡‡‡fd†}||_ dS(Ncs!ˆƒz ˆƒSWdˆƒXdS(N(((tracquireR3trrelease(s3/mit/python/lib/python2.6/multiprocessing/queues.pyRCPs cs$ˆƒzˆ|ƒSWdˆƒXdS(N((R<(RuRvR1(s3/mit/python/lib/python2.6/multiprocessing/queues.pyR?^s( RR3RR7R;RCRRRR1R?(R!RCR?((RuRƒR1RvR3R„s3/mit/python/lib/python2.6/multiprocessing/queues.pyR‚Ms   (RxRyR#RGR$R&R‚(((s3/mit/python/lib/python2.6/multiprocessing/queues.pyR7s    (t__all__RRR'R)R@tatexitR]RRRRtmultiprocessingRtmultiprocessing.synchronizeRRRRtmultiprocessing.utilR R R R tmultiprocessing.forkingR tobjectRdR{R(((s3/mit/python/lib/python2.6/multiprocessing/queues.pyt s"         ""ç (