Dh80dZddlmZddlZddlZddlZddlmZejrddl m Z ddl m Z ddl m Z e d Zd ZGd d ej Zej$ d dd Zej$dddZ d ddZy)z/Threaded implementation. Asyncio is supported ) annotationsN)class_decorator) Awaitable)Callable) ParamSpecSpec)ThreadedthreadedceZdZdZdZ d d fd Zed dZed dZed dZ ddZ ddZ dfd Z xZ S)r z Run function in separate thread.)__name__daemon __startedc ||_||_t|r*|}dt|dt t |z|_n d|c}|_t|!|y)aRun function in separate thread. :param name: New thread name. If callable: use as wrapped function. If none: use wrapped function name. :type name: typing.Optional[typing.Union[str, Callable[..., typing.Union[Awaitable, typing.Any]]]] :param daemon: Daemonize thread. :type daemon: bool :param started: Return started thread :type started: bool Threaded: __name__N)func) _Threaded__daemon_Threaded__startedcallablegetattrstrhash_Threaded__namesuper__init__)selfnamedaemonstartedr __class__s t/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/threaded/_threaded.pyrzThreaded.__init__.s]"% & D>MQD&2WT:sSWX\S]5_&_DK $d D$+ d#c|jS)z;Thread name. :rtype: typing.Optional[str] )rrs r"rz Threaded.nameHs {{r#c|jS)z6Start thread as daemon. :rtype: bool )rr%s r"rzThreaded.daemonPs }}r#c|jS)z5Return started thread. :rtype: bool )rr%s r"r zThreaded.startedXs ~~r#c|jjd|jd|jd|jdS)zLFor debug purposes. :return: repr data :rtype: str z(name=z , daemon=z , started=z, ))r!rrrr r%s r"__repr__zThreaded.__repr__`s@ ..))*& Yt{{oU_`d`l`l_oorssr#c j|j"dt|dtt |zt j dfd }|S)aHere should be constructed and returned real decorator. :param func: Wrapped function :type func: Callable[..., typing.Union[Awaitable, typing.Any]] :return: wrapped function :rtype: Callable[..., threading.Thread] rrctj||j}jr|j |S)zdThread getter. :return: Thread object :rtype: threading.Thread )targetrargskwargsr) threadingThreadrr start)r-r.threadrpreparedrs r"wrapperz/Threaded._get_function_wrapper..wrapperxs:%%XDtTZcgcncnoF|| Mr#)r-z Spec.argsr.z Spec.kwargsreturnzthreading.Thread)_await_if_requiredrrrr functoolswraps)rrr4rr3s` @@r"_get_function_wrapperzThreaded._get_function_wrapperhsb04/F/Ft/L99 <'$ CT O"LLD  "  # r#c"t||i|S)zExecutable instance. :return: Thread object or Thread getter :rtype: Union[threading.Thread, Callable[..., threading.Thread]] )r__call__)rr-r.r!s r"r;zThreaded.__call__sw000r#NFF)rz@None | (str | Callable[..., Awaitable[typing.Any] | typing.Any])rboolr r=r5None)r5 str | None)r5r=)r5r)rz2Callable[Spec, Awaitable[typing.Any] | typing.Any]r5Callable[..., threading.Thread])r-z>Callable[..., Awaitable[typing.Any] | typing.Any] | typing.Anyr.z typing.Anyr5z2threading.Thread | Callable[..., threading.Thread])r __module__ __qualname____doc__ __slots__rpropertyrrr r)r9r; __classcell__)r!s@r"r r )s*3IRV $N$$ $  $4tF (< 1M 1 1 < 1 1r#r cy)z+Overload: Call decorator without arguments.Nrrr s r"r r r#cy)zOverload: Name is not callable.NrHrIs r"r r rJr#c t|r8|dt|dtt|z}}t ||||St |||S)a Run function in separate thread. :param name: New thread name. If callable: use as wrapped function. If none: use wrapped function name. :type name: typing.Union[None, str, Callable] :param daemon: Daemonize thread. :type daemon: bool :param started: Return started thread :type started: bool :return: Threaded instance, if called as function or argumented decorator, else callable wrapper :rtype: typing.Union[Threaded, Callable[..., threading.Thread]] rrrI)rrrrr )rrr rs r"r r s_$~L74Sd_+UUd x     fg >>r#)FF)rzCallable[..., typing.Any]rr=r r=r5r@r<)rr?rr=r r=r5r )rz&str | Callable[..., typing.Any] | Nonerr=r r=r5z*Threaded | Callable[..., threading.Thread])rC __future__rr7r/typingr TYPE_CHECKINGcollections.abcrrtyping_extensionsrr __all__ BaseDecoratorr overloadr rHr#r"rVs #  )(+ V D "g1,,g1TKP6 #6-16DH6$66 ** 48? 0? ??0 ?r#