'j(ddlZGddZdS)NceZdZdZd dZedZejdZedZejdZdZ d Z d S) Throttlea( Helper class that wrap a function with a given max execution rate. By default the rate is set to execute no more than once a second. :param fn: the function to call. :type fn: function :param ts: Number of seconds to wait before the next execution. :type ts: float ch||_||_d|_d|_d|_g|_i|_dS)NrF)_ts_fn _requests_pending _pending_task _last_args _last_kwargs)selffntss T/DATA/AppData/hermes/venv/lib/python3.11/site-packages/trame_common/exec/throttle.py__init__zThrottle.__init__s; !cd|jz S)z'Number of maximum executions per second?rrs rratez Throttle.ratesTX~rcd|z |_dS)z3Update the maximum number of executions per secondsrNr)rrs rrz Throttle.rates:rc|jS)z+Number of seconds to wait between executionrrs rdelta_tzThrottle.delta_t#s xrc||_dS)z6Update the number of seconds to wait between executionNr)rsecondss rrzThrottle.delta_t(srcKd|_|jr|j|ji|jd|_t j|jd{V|jdkr|d{Vd|_dS)NTrF) r r rr r asynciosleepr_trottlers rr!zThrottle._trottle-s >  DHdo ;): ; ; ;DNmDH%%%%%%%%% >A  --// ! ! ! ! ! ! ! rc|xjdz c_||_||_|js-t j||_dSdS)zUFunction call wrapper that will throttle the actual function provided at constructionrN)r r r r r create_taskr!r )rargskwargss r__call__zThrottle.__call__8sY !"} F!(!4T]]__!E!ED    F FrN)r) __name__ __module__ __qualname____doc__rpropertyrsetterrr!r&rrrrs  X [[X ^^   FFFFFrr)rrr-rrr.sJ;F;F;F;F;F;F;F;F;F;Fr