Process pool with concurrency io loops thread pool

executor2.py

import time
import asyncio
from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor, as_completed


class SyncWork:
    def __init__(self):
        self.active_tasks_limit = 10

    def __call__(self, *args, **kwargs):
        pass


class AsyncWork:
    def __init__(self):
        pass

    async def __call__(self, *args, **kwargs):
        pass


async def iotask():
    print("One")
    await asyncio.sleep(1)
    print("Two")
    return 1


async def iorun():
    return await asyncio.gather(*[iotask() for _ in range(4)])


def turboio():
    return asyncio.run(iorun())


def task():
    time.sleep(3)
    return "task slept 3s"


def tpool():
    c = 0
    with ThreadPoolExecutor() as pool:
        futures = {pool.submit(task) for _ in range(16)}
        for future in as_completed(futures):
            print(future.result())
            c += 1
    print(c)


def ppool():
    with ProcessPoolExecutor() as pool:
        # for task in tasks:
        futures = {pool.submit(turboio) for _ in range(4)}
        for future in as_completed(futures):
            print(future.result())


def main():
    ppool()


if __name__ == "__main__":
    main()