← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/anyio/__pycache__/to_thread.cpython-312.pyc
43 lines
�
c�bj�
� �� � d dl mZ dZd dlZd dlmZ d dlmZmZ d dl m
Z
ddl m Z erdd l
mZ ej d
k\ r d d lmZmZ nd d lmZmZ ed � Z ed
� Zdddd� dd�Zdd�Zy)� )� annotations)�run_sync� current_default_thread_limiterN)�Callable)�
TYPE_CHECKING�TypeVar)�warn� )�get_async_backend)�CapacityLimiter)� � )� TypeVarTuple�Unpack�T_Retval�PosArgsTF)�abandon_on_cancel� cancellable�limiterc � � K � |�|}t dt d�� t � j | |||�� � d{ ��� S 7 ��w)aL
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.
Nz�The `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)�funcr r r �argss �f/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/anyio/to_thread.pyr r sY � �� �: � � '�� �
M� ��
� #�$�>�>� �d�&7�� ?� � � � �s �7A �>�A c �2 � t � j � S )a
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 r � � r r r F s � � � � =� =� ?�?r ) r z&Callable[[Unpack[PosArgsT]], T_Retval]r zUnpack[PosArgsT]r �boolr z bool | Noner zCapacityLimiter | None�returnr )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>r- s� �� "� ��
� $� )� � /��7����w� �+�+�6� �:� �� �
� #�� $� #�&*� (�
0�(� �(� �(� � (�
$� (� �
(�V
@r