o tf @sddlmZddlmZddlmZmZmZddlm Z m Z m Z m Z m Z mZmZe r.ddlZddlmZddlmZe ee d fge fZeeefZGd d d eZddddZdS)) annotations)Queue)Threadcurrent_thread main_thread) TYPE_CHECKINGAnyCallableClassVar DefaultDictLiteralTupleN) EmitLoopError) WeakCallback.c@sFeZdZUdZeeZded< ddd d ZddddZ dddZ dS)QueuedCallbackaWeakCallback that queues the callback to be called on a different thread. (...rather than invoking it immediately.) Parameters ---------- wrapped : WeakCallback The actual callback to be invoked. thread : Thread | Literal["main", "current"] | None The thread on which to invoke the callback. If not provided, the main thread will be used. z=ClassVar[collections.defaultdict[Thread, Queue[CbArgsTuple]]] _GLOBAL_QUEUENwrappedrthread*Thread | Literal['main', 'current'] | NonereturnNonecCs~||_|j|_|j|_|j|_|j|_|dus|dkrt}n|dkr't}nt|ts6t dt |j ||_ |j |_ dS)Nmaincurrentz(`thread` must be a Thread instance, not )_wrapped_keyZ _max_args_aliveZ _on_ref_errorrr isinstancer TypeErrortype__name__ _cbthreadpriority)selfrrr$W/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/psygnal/_queue.py__init__$s  zQueuedCallback.__init__r$argstuplecCs:t|jur|j|dStj|j|jj|fdSN)rr!rcbrrput)r#r'r$r$r%r*>s zQueuedCallback.cbCallable | NonecCs |jSr))r dereference)r#r$r$r%r-Ds zQueuedCallback.dereferencer))rrrrrr)r$)r'r(rr)rr,) r __module__ __qualname____doc__r rr__annotations__r&r*r-r$r$r$r%rs   rr Thread | Nonerrc Csr|durtn|}tj|}|s7|\}}z||Wnty0}zt|d|d}~ww|rdSdS)a)Trigger emissions of all callbacks queued in the current thread. Parameters ---------- thread : Thread, optional The thread on which to invoke the callback. If not provided, the main thread will be used. Raises ------ EmitLoopError If an exception is raised while invoking a queued callback. This exception can be caught and optionally suppressed or handled by the caller, allowing the emission of other queued callbacks to continue even if one of them raises an exception. N)exc)rrremptyget Exceptionr)r_threadqueuer*r'er$r$r% emit_queuedHs    r:r))rr2rr) __future__rr8r threadingrrrtypingrrr r r r r collections _exceptionsrZ_weak_callbackrZCallbackr(Z CbArgsTuplerr:r$r$r$r%s $   6