`gj XdZddlmZddlZddlZddlmZddlmZdgZ GddeZ y)uShared daemon-thread ThreadPoolExecutor. Stdlib ``ThreadPoolExecutor`` workers are non-daemon AND are registered in ``concurrent.futures.thread._threads_queues``, whose atexit hook (``_python_exit``) joins every worker unconditionally — even after ``shutdown(wait=False)``. A single wedged worker (tool blocked on network I/O, hung provider daemon, stuck subagent) therefore blocks interpreter exit forever. This is the root cause of multi-minute CLI exits on long sessions: every abandoned concurrent-tool batch leaves workers that the exit hook insists on joining. ``DaemonThreadPoolExecutor`` spawns daemon workers and skips the ``_threads_queues`` registration, so: - ``_python_exit`` never joins them, and - the interpreter's non-daemon thread join at shutdown skips them. Semantics are otherwise identical (initializer/initargs, work queue, idle-thread reuse). Use it for any pool whose work is best-effort or independently interruptible and must never hold the process open: concurrent tool execution, background memory sync, catalog fan-out, subagent timeout wrappers. Do NOT use it for work that must complete before exit (durable writes) — those belong on foreground threads with explicit bounded joins. ) annotationsN)ThreadPoolExecutor)_workerDaemonThreadPoolExecutorceZdZdZddZy)rzCThreadPoolExecutor variant whose workers do not block process exit.c|jjdry|jfd}t|j}||j krd|j xs||fz}tj|ttj|||j|j|jfd}|j|jj|yy)Nr)timeoutc&|jdy)N)put)_qs D/root/.hermes/venv/lib/python3.12/site-packages/tools/daemon_pool.py weakref_cbzADaemonThreadPoolExecutor._adjust_thread_count..weakref_cb.s EE$Kz%s_%dT)nametargetargsdaemon)_idle_semaphoreacquire _work_queuelen_threads _max_workers_thread_name_prefix threadingThreadrweakrefref _initializer _initargsstartadd)selfr num_threads thread_namets r_adjust_thread_countz-DaemonThreadPoolExecutor._adjust_thread_count(s    ' ' ' 2  ,, $--( ** *!T%=%=%E{$SSK   KKj1$$%%NN   A GGI MM  a  +rN)returnNone)__name__ __module__ __qualname____doc__r(rrrr%s M!r) r. __future__rrrconcurrent.futuresrconcurrent.futures.threadr__all__rr/rrr4s04#1- % &!1!r