3 ]ð]wã @s°dZddlZyddlmZWn ek r<ddlmZYnXddlmZddlmZGdd„dƒZ Gdd „d e ƒZ Gd d „d e ƒZ Gd d „d e ƒZ Gdd„de ƒZdd„ZdS)z&Utilities for multi-threading support.éN)Ú monotonic)Útime)ÚExceededMaxWaitersc@s@eZdZddd„Zddd„ZeZdd „Zd d „Zed d „ƒZ dS)Ú SemaphoreécCs*|dkrtdƒ‚tjtjƒƒ|_||_dS)Nrz$semaphore initial value must be >= 0)Ú ValueErrorÚ threadingÚ ConditionÚLockÚ_condÚ_value)ÚselfÚvalue©rú6/tmp/pip-build-20mum3z4/pymongo/pymongo/thread_util.pyÚ__init__ szSemaphore.__init__TNcCs˜| r|dk rtdƒ‚d}d}|jjƒx`|jdkrx|s:P|dk rj|dkrVtƒ|}n|tƒ}|dkrjP|jj|ƒq*W|jd|_d}|jjƒ|S)Nz.can't specify timeout for non-blocking acquireFrrT)rr Úacquirer Ú_timeÚwaitÚrelease)r ÚblockingÚtimeoutÚrcÚendtimerrrr&s&      zSemaphore.acquirecCs.|jjƒ|jd|_|jjƒ|jjƒdS)Nr)r rr Únotifyr)r rrrr?s   zSemaphore.releasecCs |jƒdS)N)r)r ÚtÚvÚtbrrrÚ__exit__EszSemaphore.__exit__cCs|jS)N)r )r rrrÚcounterHszSemaphore.counter)r)TN) Ú__name__Ú __module__Ú __qualname__rrÚ __enter__rrÚpropertyrrrrrrs   rc@s"eZdZdZddd„Zdd„ZdS) ÚBoundedSemaphorez6Semaphore that checks that # releases is <= # acquiresrcCstj||ƒ||_dS)N)rrÚ_initial_value)r rrrrrOs zBoundedSemaphore.__init__cCs|j|jkrtdƒ‚tj|ƒS)Nz!Semaphore released too many times)r r&rrr)r rrrrSs zBoundedSemaphore.releaseN)r)r r!r"Ú__doc__rrrrrrr%Ms r%c@s(eZdZd dd„Zd dd„Zdd„ZdS) ÚDummySemaphoreNcCsdS)Nr)r rrrrr[szDummySemaphore.__init__TcCsdS)NTr)r rrrrrr^szDummySemaphore.acquirecCsdS)Nr)r rrrraszDummySemaphore.release)N)TN)r r!r"rrrrrrrr(Zs  r(c@s(eZdZd dd„Zd dd„Zdd „ZdS) ÚMaxWaitersBoundedSemaphorercCs||ƒ|_||ƒ|_dS)N)Úwaiter_semaphoreÚ semaphore)r Zsemaphore_classrÚ max_waitersrrrrfs z#MaxWaitersBoundedSemaphore.__init__TNc Cs2|jjdƒstƒ‚z|jj||ƒS|jjƒXdS)NF)r*rrr+r)r rrrrrrjs  z"MaxWaitersBoundedSemaphore.acquirecCs t|j|ƒS)N)Úgetattrr+)r ÚnamerrrÚ __getattr__rsz&MaxWaitersBoundedSemaphore.__getattr__)rr)TN)r r!r"rrr/rrrrr)es  r)c@seZdZddd„ZdS)Ú MaxWaitersBoundedSemaphoreThreadrcCstj|t||ƒdS)N)r)rr%)r rr,rrrrwsz)MaxWaitersBoundedSemaphoreThread.__init__N)rr)r r!r"rrrrrr0vsr0cCs,|dkrtƒS|dkrt|ƒSt||ƒSdS)N)r(r%r0)Úmax_sizer,rrrÚcreate_semaphore|s r2)r'rrrrÚ ImportErrorZpymongo.monotonicZpymongo.errorsrrr%Úobjectr(r)r0r2rrrrÚs  1