o 0׾g @sdZddlmZddlmZddlmZddlmZgdZ e egd\Z Z Z dd d ZGd d d eZGd ddeZGdddeZdS)z A small selection of primitives that always work with native threads. This has very limited utility and is targeted only for the use of gevent's threadpool. )absolute_import)deque)monkey)thread_mod_name)LockQueue EmptyTimeout)start_new_thread allocate_lock get_identcCst|jtd<|j|dS)Nacquire_with_timeout)timeout)typeacquireglobals)lockrr[/var/www/html/backend_erp/backend_erp_env/lib/python3.10/site-packages/gevent/_threading.pyr "s r c@sFeZdZdZddZddZddZdd Zd efd d Z d dZ dS) _Condition_lock_waiterscCs||_g|_dSNr)selfrrrr__init__2s z_Condition.__init__cCs |jSr)r __enter__rrrrr=s z_Condition.__enter__cCs|j|||Sr)r__exit__)rtvtbrrrr@sz_Condition.__exit__cCsd|jt|jfS)Nz)rlenrrrrr__repr__Csz_Condition.__repr__r cCs~d}||j||jz |||}W|jn|jw|s+|d}|s9|j|||S||S)NTF)rrappendrreleaseremove)r wait_lockr_wait_for_notifygevent_threadpool_worker_idlenotifiedrrrwaitFs     z_Condition.waitcCs0z|j}Wn tyYdSw|dSr)rpop IndexErrorr%)rwaiterrrr notify_onems   z_Condition.notify_oneN) __name__ __module__ __qualname__ __slots__rrrr#r r+r/rrrrr's  'rc@seZdZdZdS)rzERaised from :meth:`Queue.get` if no item is available in the timeout.N)r0r1r2__doc__rrrrrzsrc@sbeZdZdZdZddZddZefddZd d Z d d Z d dZ dddZ ddZ ddZdS)rzH Create a queue object. The queue is always infinite size. _queue_mutex _not_emptyunfinished_taskscCs&t|_t|_t|j|_d|_dS)Nr)rr6rr7rr8r9rrrrrs  zQueue.__init__cCsZ|j |jd}|dkr|dkrtd|j||_WddS1s&wYdS)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. rz5task_done() called too many times; %s remaining tasksN)r7r9 ValueError)r unfinishedrrr task_dones "zQueue.task_donecCs ||jS)z9Return the approximate size of the queue (not reliable!).)r6)rr"rrrqsize z Queue.qsizecCs | S)zCReturn True if the queue is empty, False otherwise (not reliable!).)r>rrrremptyr?z Queue.emptycCsdS)zBReturn True if the queue is full, False otherwise (not reliable!).Frrrrrfullsz Queue.fullcCsP|j|j||jd7_|jWddS1s!wYdS)z$Put an item into the queue. r:N)r7r6r$r9r8r/)ritemrrrputs   "z Queue.putr cCs`|j#|js|j||}|s|jst|jr|j}|WdS1s)wYdS)a" Remove and return an item from the queue. If *timeout* is given, and is not -1, then we will attempt to wait for only that many seconds to get an item. If those seconds elapse and no item has become available, raises :class:`EmptyTimeout`. N)r7r6r8r+rpopleft)rcookierr*rBrrrgets   $z Queue.getcCstS)z Create and return the *cookie* to pass to `get()`. Each thread that will use `get` needs a distinct cookie. )rrrrrallocate_cookieszQueue.allocate_cookiecCsd|_d|_d|_d|_dS)z Call to destroy this object. Use this when it's not possible to safely drain the queue, e.g., after a fork when the locks are in an uncertain state. Nr5rrrrkills z Queue.killNr )r0r1r2r4r3rr=r"r>r@rArCrFrGrHrrrrr~s   rNrI)r4 __future__r collectionsrgeventrgevent._compatr__all__ get_originalr rget_thread_identr objectr Exceptionrrrrrrs     S