U /e7 @s2ddlmZddlZddlmZGdddZdS)) annotationsN)timec@sxeZdZdZdddddZddd d Zddd d Zd dddZddddZdddddZ dddddZ dS)ResourceLimiteraLimit an abstract resource This allows us to track usage of an abstract resource. If the usage of this resources goes beyond a defined maxvalue, we can block further execution Example:: limiter = ResourceLimiter(2) limiter.increase(1) limiter.increase(2) limiter.decrease(1) # This will block since we're still not below maxvalue await limiter.wait_for_available() intNone)maxvaluereturncCs,||_d|_t|_d|_d|_d|_dS)Nrg) _maxvalue _acquiredasyncio Condition _condition_waiterstime_blocked_totaltime_blocked_avg)selfrr@/tmp/pip-unpacked-wheel-g426oqom/distributed/shuffle/_limiter.py__init__s  zResourceLimiter.__init__str)rcCsd|jd|dS)Nz)r availablerrrr__repr__!szResourceLimiter.__repr__cCstd|j|jS)z2How far can the value be increased before blockingr)maxr r rrrrr$szResourceLimiter.availableboolcCs |jdkS)zLReturn True if nothing has been acquired / the limiter is in a neutral staterr rrrrfree(szResourceLimiter.freec st}d}zn|rWbdS|j4IdH@|jd7_|j|jIdH|jd8_t|}W5QIdHRXW5|j|7_|jd|d|_XdS)z,Block until the counter drops below maxvaluerg?g?N)rrrrr rwait_for)rstartdurationrrrwait_for_available,sz"ResourceLimiter.wait_for_available)valuercCs|j|7_dS)z&Increase the internal counter by valueNrrr#rrrincrease<szResourceLimiter.increasec s\||jkr td|d|j|j|8_|j4IdH|jW5QIdHRXdS)z&Decrease the internal counter by valuez5Cannot release more than what was acquired! release: z acquired: N)r RuntimeErrorr notify_allr$rrrdecrease@s zResourceLimiter.decreaseN) __name__ __module__ __qualname____doc__rrrrr"r%r(rrrrrsr) __future__rr Zdistributed.metricsrrrrrrs