Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.8/site-packages/anyio/to_thread.py: 60%
15 statements
« prev ^ index » next coverage.py v7.2.2, created at 2023-03-26 06:12 +0000
« prev ^ index » next coverage.py v7.2.2, created at 2023-03-26 06:12 +0000
1from typing import Callable, Optional, TypeVar
2from warnings import warn
4from ._core._eventloop import get_asynclib
5from .abc import CapacityLimiter
7T_Retval = TypeVar("T_Retval")
10async def run_sync(
11 func: Callable[..., T_Retval],
12 *args: object,
13 cancellable: bool = False,
14 limiter: Optional[CapacityLimiter] = None
15) -> T_Retval:
16 """
17 Call the given function with the given arguments in a worker thread.
19 If the ``cancellable`` option is enabled and the task waiting for its completion is cancelled,
20 the thread will still run its course but its return value (or any raised exception) will be
21 ignored.
23 :param func: a callable
24 :param args: positional arguments for the callable
25 :param cancellable: ``True`` to allow cancellation of the operation
26 :param limiter: capacity limiter to use to limit the total amount of threads running
27 (if omitted, the default limiter is used)
28 :return: an awaitable that yields the return value of the function.
30 """
31 return await get_asynclib().run_sync_in_worker_thread(
32 func, *args, cancellable=cancellable, limiter=limiter
33 )
36async def run_sync_in_worker_thread(
37 func: Callable[..., T_Retval],
38 *args: object,
39 cancellable: bool = False,
40 limiter: Optional[CapacityLimiter] = None
41) -> T_Retval:
42 warn(
43 "run_sync_in_worker_thread() has been deprecated, use anyio.to_thread.run_sync() instead",
44 DeprecationWarning,
45 )
46 return await run_sync(func, *args, cancellable=cancellable, limiter=limiter)
49def current_default_thread_limiter() -> CapacityLimiter:
50 """
51 Return the capacity limiter that is used by default to limit the number of concurrent threads.
53 :return: a capacity limiter object
55 """
56 return get_asynclib().current_default_thread_limiter()
59def current_default_worker_thread_limiter() -> CapacityLimiter:
60 warn(
61 "current_default_worker_thread_limiter() has been deprecated, "
62 "use anyio.to_thread.current_default_thread_limiter() instead",
63 DeprecationWarning,
64 )
65 return current_default_thread_limiter()