:jQdZddlZddlmZmZddlmZddlmZedZ GddeZ Gd d e Z Gd d e Z Gd de Z y)zE Base classes for thread lifecycle management in manager components. N)ABCabstractmethod)Optional) get_loggermanagerc~eZdZdZdefdZddZddeeddfdZ de fd Z dd Z e de fd Zdd Zdd ZddZy)LifecycleManagerz0Base class for components that manage lifecycle.namec`||_d|_d|_tj|_y)zk Initialize lifecycle manager. Args: name: Component name for logging FN)r running_externally_finished threadingLock_lock)selfr s 3/root/.openclaw/workspace/harvester/manager/base.py__init__zLifecycleManager.__init__s,  %*!^^% returnNc(|j5|jr,tj|jd dddyd|_|j tj d|jdddy#1swYyxYw)zStart the component.z already runningNTStarted )rr loggerwarningr _on_startinfors rstartzLifecycleManager.start#sv ZZ 0||$)),<=> 0 0  DL NN  KK(499+. / 0 0 0s0B9BBtimeoutc|jsy|j5d|_|jddd|jtj d|j y#1swY LL9TYYKy< = = > LLDII;&67 8s&5 A-%A(#A0(A--A00$Bcy)z Main thread loop implementation.Nr+rs rrSzThreadManager._main_loop r)@Tr/r0)r1r2r3r4r5r6r7rrrr#rIrrS __classcell__rDs@rr:r:\sUC-S-E--(0,,HUO,t,29  rr:cLeZdZdZddededeffd Zd dZed dZ xZ S) PeriodicTaskManagerz6Base class for components that perform periodic tasks.r intervalr;cZt|||tdt||_y)z Initialize periodic task manager. Args: name: Component name for logging interval: Interval between task executions in seconds shutdown_timeout: Maximum time to wait for graceful shutdown 皙?N)r?rr@r6r`)rr r`r;rDs rrzPeriodicTaskManager.__init__s' /0Cx1 rc|jrQ |j|jr&|jj|j|jrPyy#t $rk}t jd|jd||jr0|jjtd|jYd}~~d}~wwxYw)z'Main loop that executes periodic tasks.rLrRz periodic task: r>N) r _execute_periodic_taskrCwaitr`rTrrUr minrWs rrSzPeriodicTaskManager._main_loopsll K++-<<$$))$--)@ll K y 3CA3GH<<$$))#c4==2I)J  KsAA C(A!CCcy)zExecute the periodic task.Nr+rs rrdz*PeriodicTaskManager._execute_periodic_taskrZr)r[r/) r1r2r3r4r5r6rrSrrdr\r]s@rr_r_s:@ 2S 2E 2U 2K"  rr_cbeZdZdZd dededeffd Zd dZede fdZ ed d Z xZ S) ConditionalTaskManagerz5Base class for components that respond to conditions.r check_intervalr;cZt|||tdt||_y)a Initialize conditional task manager. Args: name: Component name for logging check_interval: Interval between condition checks in seconds shutdown_timeout: Maximum time to wait for graceful shutdown rbN)r?rr@r6rj)rr rjr;rDs rrzConditionalTaskManager.__init__s) /0!#u^'<=rrc|jra |jr|j|jr&|jj |j |jr`yy#t $rk}tjd|jd||jr0|jj td|j Yd}~~d}~wwxYw)z8Main loop that checks conditions and responds to events.rLrRz condition handling: r>N) r _should_execute_handle_conditionrCrerjrTrrUr rfrWs rrSz!ConditionalTaskManager._main_loopsll Q'')**,<<$$))$2E2E)Fll Q y 3HLM<<$$))#c4;N;N2O)P  QsAA// C#8A!CC#cy)z%Check if condition should be handled.Nr+rs rrmz&ConditionalTaskManager._should_executerZrcy)zHandle the detected condition.Nr+rs rrnz(ConditionalTaskManager._handle_conditionrZr)r>r[r/) r1r2r3r4r5r6rrSrr7rmrnr\r]s@rririsV? >S >% >QV >Q$     rri)r4rabcrrtypingr tools.loggerrrr r:r_rir+rrrtsZ## I I sI XR $R j# -# L) ]) r