معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

asyncio-powered coroutine worker pool

ویژگی	مقدار
سیستم عامل	-
نام فایل	aioutilities-1.0.3
نام	aioutilities
نسخه کتابخانه	1.0.3
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Kevin Kirsche
ایمیل نویسنده	kev.kirsche@gmail.com
آدرس صفحه اصلی	https://github.com/kkirsche/aioutilities
آدرس اینترنتی	https://pypi.org/project/aioutilities/
مجوز	MIT

# aioutilities `asyncio`-powered coroutine worker pool. No more juggling bounded semaphores and annoying timeouts, and allows you to run through millions of pieces of data efficiently. # Installation ```shell python -m pip install -U aioutilities ``` # Credits This is refactored and built on top of https://github.com/CaliDog/asyncpool # Example Usage ```python from asyncio import Queue, ensure_future, run, sleep from aioutilities.pool import AioPool async def example_coro(initial_number: int, result_queue: Queue[int]) -> None: result = initial_number * 2 print(f"Processing Value! -> {initial_number} * 2 = {result}") await sleep(1) await result_queue.put(initial_number * 2) async def result_reader(queue: Queue[int | None]) -> None: while True: value = await queue.get() if value is None: break print(f"Got value! -> {value}") async def example() -> None: result_queue = Queue[int | None]() reader_future = ensure_future(result_reader(result_queue)) # Start a worker pool with 10 coroutines, invokes `example_coro` and waits for # it to complete or 5 minutes to pass. pool = AioPool[int]( name="ExamplePool", task=example_coro, worker_qty=10, timeout=300, ) async with pool.spawn() as workers: for i in range(50): await workers.push(i, result_queue) await result_queue.put(None) await reader_future def run_example() -> None: run(example()) ```

زبان مورد نیاز

مقدار	نام
>=3.8,<4	Python

نحوه نصب

نصب پکیج whl aioutilities-1.0.3:

pip install aioutilities-1.0.3.whl

نصب پکیج tar.gz aioutilities-1.0.3:

pip install aioutilities-1.0.3.tar.gz