B H/\@sxdZddlmZddlmZddlmZddlmZddgZ e edd d g\Z Z Z Gd d d eZGd ddeZdS)aA 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'. )absolute_import)deque)monkey)thread_mod_nameLockQueuestart_new_thread allocate_lock get_identc@sTeZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ dS) _ConditioncCsv||_g|_y |j|_Wntk r,YnXy |j|_Wntk rNYnXy |j|_Wntk rpYnXdS)N)_Condition__lock_Condition__waiters _release_saveAttributeError_acquire_restore _is_owned)selflockr0lib/python3.7/site-packages/gevent/_threading.py__init__"s   z_Condition.__init__cCs |jS)N)r __enter__)rrrrr6sz_Condition.__enter__cCs|j|||S)N)r __exit__)rtvtbrrrr9sz_Condition.__exit__cCsd|jt|jfS)Nz)r lenr )rrrr__repr__<sz_Condition.__repr__cCs|jdS)N)r release)rrrrr?sz_Condition._release_savecCs|jdS)N)r acquire)rxrrrrBsz_Condition._acquire_restorecCs|jdr|jdSdS)NrFT)r rr)rrrrrEs  z_Condition._is_ownedc Cs@t}||j||}z |Wd||XdS)N)rrr appendrr)rwaiterZ saved_staterrrwaitMs  z_Condition.waitcCs0y|j}Wntk r"Yn X|dS)N)r pop IndexErrorr)rr"rrr notify_oneXs z_Condition.notify_oneN) __name__ __module__ __qualname__rrrrrrrr#r&rrrrr s r c@sPeZdZdZdZddZddZefddZd d Z d d Z d dZ ddZ dS)rzCCreate a queue object. The queue is always infinite size. )_queue_mutex _not_emptyunfinished_taskscCs&t|_t|_t|j|_d|_dS)Nr)rr*rr+r r,r-)rrrrrks zQueue.__init__c Cs>|j.|jd}|dkr*|dkr*td||_WdQRXdS)a.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. rz!task_done() called too many timesN)r+r- ValueError)rZ unfinishedrrr task_donexs  zQueue.task_donecCs ||jS)z9Return the approximate size of the queue (not reliable!).)r*)rrrrrqsizesz Queue.qsizecCs | S)zCReturn True if the queue is empty, False otherwise (not reliable!).)r1)rrrremptysz Queue.emptycCsdS)zBReturn True if the queue is full, False otherwise (not reliable!).Fr)rrrrfullsz Queue.fullc Cs:|j*|j||jd7_|jWdQRXdS)z$Put an item into the queue. r.N)r,r*r!r-r&)ritemrrrputs z Queue.putc Cs6|j&x|js|jq W|j}|SQRXdS)z2Remove and return an item from the queue. N)r,r*r#popleft)rr4rrrgets  z Queue.getN) r'r(r)__doc__ __slots__rr0rr1r2r3r5r7rrrrrcs  N)r8Z __future__r collectionsrZgeventrZgevent._compatr__all__Z get_originalrrZget_thread_identobjectr rrrrrs    D