\jHddlmZddlmZmZddlZddlmZGddZy))log)EventThreadN)Callablec6eZdZdZdededefdZdZdZdZ y ) RepeatingTaskzf A generic mechanism for calling a callback repeatedly at fixed intervals on a worker thread. interval initial_delaycallablec||_||_||_t|_t |j |_d|j_y)a9 Creates the task, but does not start the worker thread yet. :param interval: maximum time in seconds between invocations of the callback :param initial_delay: time in seconds to wait before the first invocation :param callable: the function to execute repeatedly )targetTN) _RepeatingTask__interval_RepeatingTask__initial_delay_RepeatingTask__actionr_RepeatingTask__stopr_run_RepeatingTask__threaddaemon)selfr r r s F/root/env/lib/python3.12/site-packages/ldclient/impl/repeating_task.py__init__zRepeatingTask.__init__ s?#,  g dii0 # c8|jjy)z+ Starts the worker thread. N)rstartrs rrzRepeatingTask.starts rc8|jjy)zU Tells the worker thread to stop. It cannot be restarted after this. N)rsetrs rstopzRepeatingTask.stop s rc|jdkDr&|jj|jry|jj}|st j|j z} |j |t jz }|dkDr|jj|n|jj}|syy#t$r"}tjd|zYd}~|d}~wwxYw)Nrz)Unexpected exception on worker thread: %s) rrwaitis_settimerr Exceptionr exception)rstopped next_timeedelays rrzRepeatingTask._run&s   ! #{{ 4 45++$$& doo5I O  +E16dkk&&u- @R@R@TG O IAMNN Os4C D#DDN) __name__ __module__ __qualname____doc__floatrrrrrrrrrs1 $ $u $ $  Urr) ldclient.impl.utilr threadingrrr"typingrrr.rrr2s"# +U+Ur