
    1hb                        S SK Jr  S SKJrJr  S SKJr  SSKJr  SSK	J
r
  \" S5      rSS	S
.         SS jjrSS	S
.         SS jjrSS jrSS jrg	)    )annotations)CallableTypeVar)warn   )get_asynclib)CapacityLimiterT_RetvalFNcancellablelimiterc               Z   #    [        5       R                  " U /UQ7XS.6I Sh  vN $  N7f)ac  
Call the given function with the given arguments in a worker thread.

If the ``cancellable`` option is enabled and the task waiting for its completion is cancelled,
the thread will still run its course but its return value (or any raised exception) will be
ignored.

:param func: a callable
:param args: positional arguments for the callable
:param cancellable: ``True`` to allow cancellation of the operation
:param limiter: capacity limiter to use to limit the total amount of threads running
    (if omitted, the default limiter is used)
:return: an awaitable that yields the return value of the function.

r   N)r   run_sync_in_worker_threadfuncr   r   argss       G/var/www/auris/envauris/lib/python3.13/site-packages/anyio/to_thread.pyrun_syncr      s9     * 99!,   s   "+)+c               \   #    [        S[        5        [        U /UQ7XS.6I S h  vN $  N7f)NzWrun_sync_in_worker_thread() has been deprecated, use anyio.to_thread.run_sync() insteadr   )r   DeprecationWarningr   r   s       r   r   r   &   s2      	a $PP;PPPPs   #,*,c                 2    [        5       R                  5       $ )z
Return the capacity limiter that is used by default to limit the number of concurrent threads.

:return: a capacity limiter object

)r   current_default_thread_limiter     r   r   r   3   s     >88::r   c                 6    [        S[        5        [        5       $ )Nzycurrent_default_worker_thread_limiter() has been deprecated, use anyio.to_thread.current_default_thread_limiter() instead)r   r   r   r   r   r   %current_default_worker_thread_limiterr   =   s    	G
 *++r   )
r   zCallable[..., T_Retval]r   objectr   boolr   zCapacityLimiter | Nonereturnr
   )r   r	   )
__future__r   typingr   r   warningsr   _core._eventloopr   abcr	   r
   r   r   r   r   r   r   r   <module>r%      s    " $  *  : &*	
!  $	
 : &*	
Q
!
Q
Q 
Q $	
Q
 
Q;,r   