hj ddlZGddZy)NceZdZdZd dZedZejdZedZejdZdZ dZ y ) 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 cf||_||_d|_d|_d|_g|_i|_y)NrF)_ts_fn _requests_pending _pending_task _last_args _last_kwargs)selffntss G/DATA/.local/lib/python3.12/site-packages/trame_common/exec/throttle.py__init__zThrottle.__init__s5 !c d|jz S)z'Number of maximum executions per second?rr s rratez Throttle.ratesTXX~rcd|z |_y)z3Update the maximum number of executions per secondsrNr)r rs rrz Throttle.rates:rc|jS)z+Number of seconds to wait between executionrrs rdelta_tzThrottle.delta_t#s xxrc||_y)z6Update the number of seconds to wait between executionNr)r secondss rrzThrottle.delta_t(s rc>Kd|_|jr-|j|ji|jd|_t j |jd{|jdkDr|jd{d|_y737w)NTrF) r rrr r asynciosleepr_trottlers rr zThrottle._trottle-sy >> DHHdoo ;):): ;DNmmDHH%%% >>A --/ ! !  & !s$A#B%B&&B B BBc|xjdz c_||_||_|js)t j |j |_yy)zUFunction call wrapper that will throttle the actual function provided at constructionN)rr r r r create_taskr r )r argskwargss r__call__zThrottle.__call__8sD !"}}!(!4!4T]]_!ED rN)r") __name__ __module__ __qualname____doc__rpropertyrsetterrr r&rrrrso  [[ ^^ Frr)rrr-rrr.s;F;Fr