معرفی شرکت ها
aiofutures-0.1.2
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشترتوضیحات
Smoothly migrate your synchronous codebase to the asynchronous style.
| ویژگی | مقدار |
|---|---|
| سیستم عامل | - |
| نام فایل | aiofutures-0.1.2 |
| نام | aiofutures |
| نسخه کتابخانه | 0.1.2 |
| نگهدارنده | [] |
| ایمیل نگهدارنده | [] |
| نویسنده | Denis Kazakov |
| ایمیل نویسنده | denis@kazakov.ru.net |
| آدرس صفحه اصلی | https://pypi.org/project/aiofutures |
| آدرس اینترنتی | https://pypi.org/project/aiofutures/ |
| مجوز | MIT |
# Aiofutures
[](https://github.com/KazakovDenis/aiofutures/actions/workflows/cicd.yml)
- [General information](#general-information)
- [Installation](#installation)
- [Usage](#usage)
- [Implicit initialization (global executor)](#implicit-initialization-global-executor)
- [Explicit initialization](#explicit-initialization)
- [UVLoop](#uvloop)
- [Notes](#notes)
- [Contribution](#contribution)
## General information
`aiofutures` provides tools to integrate an asynchronous code into your synchronous
application in a usual and easy way using standard library's `concurrent.futures.Executor` interface.
It may be useful when you want to:
- smoothly migrate your synchronous codebase to asynchronous style
- decrease a number of threads in your application
Replace this:
```python
from concurrent.futures import ThreadPoolExecutor
with ThreadPoolExecutor() as ex:
future = ex.submit(sync_task)
result = future.result()
```
With this:
```python
from aiofutures import AsyncExecutor
with AsyncExecutor() as ex:
future = ex.submit(async_task)
result = future.result()
```
**The former spawns a lot of threads and experiences all cons of GIL, the latter
spawns the only one async thread (check out [notes](#Notes))**
## Installation
You can install `aiofutures` using pip:
```
pip install aiofutures
```
## Usage
### Implicit initialization (global executor)
Set an environment variable `AIOFUTURES_INIT` to any value and use shortcuts from the library:
```python
os.environ.setdefault('AIOFUTURES_INIT', '1')
from aiofutures import run_async
async def io_bound_task(seconds):
await asyncio.sleep(seconds)
return seconds
future = run_async(io_bound_task, 5)
print(future.result())
```
`AIOFUTURES_INIT` implicitly initializes a global `AsyncExecutor` and gives you an option to use
shortcuts `run_async` and `sync_to_async`.
### Explicit initialization
Use an instance of the `AsyncExecutor` directly:
```python
from aiofutures import AsyncExecutor
executor = AsyncExecutor()
future = executor.submit(io_bound_task, 5)
print(future.result())
```
In cases when you need to do IO synchronously within async tasks, you can use `sync_to_async`:
```python
from aiofutures import AsyncExecutor, sync_to_async
executor = AsyncExecutor()
async def io_bound_task():
# or with the shortcut
# url = await sync_to_async(fetch_url_from_db_sync)
url = await executor.sync_to_async(fetch_url_from_db_sync)
data = await fetch_data(url)
return data
future = executor.submit(io_bound_task)
print(future.result())
```
NOTE: You can use sync_to_async within tasks running in the executor only.
### UVLoop
To use with the high performance `uvloop` install it before initialization:
```python
# install before the import for the global executor
import uvloop
uvloop.install()
from aiofutures import run_async
...
# or before an explicit initialization
import uvloop
from aiofutures import AsyncExecutor
uvloop.install()
executor = AsyncExecutor()
```
### Notes
- Take into account that asyncio still ([CPython3.11](https://github.com/python/cpython/blob/4664a7cf689946f0c9854cadee7c6aa9c276a8cf/Lib/asyncio/base_events.py#L867))
resolves DNS in threads, not asynchronously
- Any blocking function will block the whole AsyncExecutor
## Contribution
All suggestions are welcome!
زبان مورد نیاز
| مقدار | نام |
|---|---|
| >=3.7,<4.0 | Python |
نحوه نصب
نصب پکیج whl aiofutures-0.1.2:
pip install aiofutures-0.1.2.whl
نصب پکیج tar.gz aiofutures-0.1.2:
pip install aiofutures-0.1.2.tar.gz