ó ÐH/\c@@s¦dZddlmZddlmZddlmZddlmZddgZ ej edd d gƒ\Z Z Z d efd „ƒYZdefd „ƒYZdS(sA clone of threading module (version 2.7.2) that always targets real OS threads. (Unlike 'threading' which flips between green and OS threads based on whether the monkey patching is in effect or not). This module is missing 'Thread' class, but includes 'Queue'. i(tabsolute_import(tdeque(tmonkey(tthread_mod_nametLocktQueuetstart_new_threadt allocate_lockt get_identt _ConditioncB@sYeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z RS( cC@s‚||_g|_y|j|_Wntk r5nXy|j|_Wntk rYnXy|j|_Wntk r}nXdS(N(t_Condition__lockt_Condition__waiterst _release_savetAttributeErrort_acquire_restoret _is_owned(tselftlock((s0lib/python2.7/site-packages/gevent/_threading.pyt__init__"s     cC@s |jjƒS(N(R t __enter__(R((s0lib/python2.7/site-packages/gevent/_threading.pyR6scC@s|jj|||ƒS(N(R t__exit__(Rtttvttb((s0lib/python2.7/site-packages/gevent/_threading.pyR9scC@sd|jt|jƒfS(Ns(R tlenR (R((s0lib/python2.7/site-packages/gevent/_threading.pyt__repr__<scC@s|jjƒdS(N(R trelease(R((s0lib/python2.7/site-packages/gevent/_threading.pyR ?scC@s|jjƒdS(N(R tacquire(Rtx((s0lib/python2.7/site-packages/gevent/_threading.pyRBscC@s'|jjdƒr#|jjƒtStS(Ni(R RRtFalsetTrue(R((s0lib/python2.7/site-packages/gevent/_threading.pyREs cC@sRtƒ}|jƒ|jj|ƒ|jƒ}z|jƒWd|j|ƒXdS(N(RRR tappendR R(Rtwaitert saved_state((s0lib/python2.7/site-packages/gevent/_threading.pytwaitMs   cC@s5y|jjƒ}Wntk r&n X|jƒdS(N(R tpopt IndexErrorR(RR ((s0lib/python2.7/site-packages/gevent/_threading.pyt notify_oneXs  ( t__name__t __module__RRRRR RRR"R%(((s0lib/python2.7/site-packages/gevent/_threading.pyR s        cB@sVeZdZd Zd„Zd„Zed„Zd„Zd „Z d „Z d „Z RS( sCCreate a queue object. The queue is always infinite size. t_queuet_mutext _not_emptytunfinished_taskscC@s7tƒ|_tƒ|_t|jƒ|_d|_dS(Ni(RR(RR)R R*R+(R((s0lib/python2.7/site-packages/gevent/_threading.pyRks  cC@sT|jE|jd}|dkrA|dkrAtdƒ‚qAn||_WdQXdS(s.Indicate that a formerly enqueued task is complete. Used by Queue consumer threads. For each get() used to fetch a task, a subsequent call to task_done() tells the queue that the processing on the task is complete. If a join() is currently blocking, it will resume when all items have been processed (meaning that a task_done() call was received for every item that had been put() into the queue). Raises a ValueError if called more times than there were items placed in the queue. iis!task_done() called too many timesN(R)R+t ValueError(Rt unfinished((s0lib/python2.7/site-packages/gevent/_threading.pyt task_donexs     cC@s ||jƒS(s9Return the approximate size of the queue (not reliable!).(R((RR((s0lib/python2.7/site-packages/gevent/_threading.pytqsizescC@s |jƒ S(sCReturn True if the queue is empty, False otherwise (not reliable!).(R/(R((s0lib/python2.7/site-packages/gevent/_threading.pytempty‘scC@stS(sBReturn True if the queue is full, False otherwise (not reliable!).(R(R((s0lib/python2.7/site-packages/gevent/_threading.pytfull•scC@s@|j1|jj|ƒ|jd7_|jjƒWdQXdS(s$Put an item into the queue. iN(R*R(RR+R%(Rtitem((s0lib/python2.7/site-packages/gevent/_threading.pytput™s cC@sD|j5x|js&|jjƒq W|jjƒ}|SWdQXdS(s2Remove and return an item from the queue. N(R*R(R"tpopleft(RR2((s0lib/python2.7/site-packages/gevent/_threading.pytget¡s   (R(R)R*R+( R&R't__doc__t __slots__RR.RR/R0R1R3R5(((s0lib/python2.7/site-packages/gevent/_threading.pyRcs     N(R6t __future__Rt collectionsRtgeventRtgevent._compatRt__all__t get_originalRRtget_thread_identtobjectR R(((s0lib/python2.7/site-packages/gevent/_threading.pyts  D