+
    Xj
                        ^ RI Ht Rt^ RIt^ RIHt ^ RIHtHt ^ RI	H
t
 ^RIHt ]'       d   ^RIHt ]P                  R8  d
   ^ RIHtHt M^ RIHtHt ]! R	4      t]! R
4      tRRRRRR/R R lltR R ltR# )    )annotationsN)Callable)TYPE_CHECKINGTypeVar)warn)get_async_backend)CapacityLimiter)TypeVarTupleUnpackT_RetvalPosArgsTabandon_on_cancelFcancellablelimiterc               0    V ^8  d   QhRRRRRRRRR	R
RR/# )   funcz&Callable[[Unpack[PosArgsT]], T_Retval]argszUnpack[PosArgsT]r   boolr   zbool | Noner   zCapacityLimiter | Nonereturnr    )formats   "k   /Users/wind/Downloads/Coruna-main学习资料A/backend/venv/lib/python3.14/site-packages/anyio/to_thread.py__annotate__r      sD     ( (
0(( ( 	(
 $( (    c                  "   Ve   Tp\        R\        ^R7       \        4       P                  WWR7      G Rj  xL
 #  L5i)a  
Call the given function with the given arguments in a worker thread.

If the ``abandon_on_cancel`` 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 abandon_on_cancel: ``True`` to abandon the thread (leaving it to run
    unchecked on own) if the host task is cancelled, ``False`` to ignore
    cancellations in the host task until the operation has completed in the worker
    thread
:param cancellable: deprecated alias of ``abandon_on_cancel``; will override
    ``abandon_on_cancel`` if both parameters are passed
:param limiter: capacity limiter to use to limit the total amount of threads running
    (if omitted, the default limiter is used)
:raises NoEventLoopError: if no supported asynchronous event loop is running in the
    current thread
:return: an awaitable that yields the return value of the function.

NzThe `cancellable=` keyword argument to `anyio.to_thread.run_sync` is deprecated since AnyIO 4.1.0; use `abandon_on_cancel=` instead)
stacklevel)r   r   )r   DeprecationWarningr   run_sync_in_worker_thread)r   r   r   r   r   s   &$$$*r   run_syncr       sT     : 'M		
 #$>>&7 ?    s   7A >A c                   V ^8  d   QhRR/# )r   r   r	   r   )r   s   "r   r   r   F   s     
@ 
@ 
@r   c                 2    \        4       P                  4       # )z
Return the capacity limiter that is used by default to limit the number of
concurrent threads.

:return: a capacity limiter object
:raises NoEventLoopError: if no supported asynchronous event loop is running in the
    current thread

)r   current_default_thread_limiterr   r   r   r#   r#   F   s     ==??r   )r    r#   )      )
__future__r   __all__syscollections.abcr   typingr   r   warningsr   _core._eventloopr   _core._synchronizationr	   version_infor
   r   typing_extensionsr   r   r    r#   r   r   r   <module>r0      s{    "
  $ )  /7w++6:
#( $(  $	(
 '+(V
@r   