feluxe / aioexec Goto Github PK

return await gather(
    *Threads().batch(
        Call(
            my_func,
            kind=item,
        ) async for item in my_async_gen
    )
)

with Threads() as pool:
    futs = [
        pool.call(
            my_func,
            kind=item,
        ) async for item in my_async_gen
    ]

    return await gather(*(f for f in futs))

async with Procs(5) as procs:

    a = await procs.call(my_func, foo='baz') 

    # Do other stuff

    b = await procs.call(my_func, foo='baz') 

    

from aioexec import Procs

aysnc def my_async_func():
    my_values = await asyncio.gather(
        *Procs(3).batch(
            Call(my_func, foo='bar'),
            Call(my_func, foo='baz'),
            Call(my_func, foo='qux'),
        )
    )

from aioexec.sync import Procs, gather

def my_non_async_func():

    # Call a single function in another process.
    future = Procs(1).call(my_func, foo='baz')
    my_value = future.result()

    # Or in one line:
    result = Procs(1).call(my_func, foo='baz').result()
    
    # Call multiple functions in a pool:
    future = gather(
        *Procs(3).batch(
            Call(my_func, foo='bar'),
            Call(my_func, foo='baz'),
            Call(my_func, foo='qux'),
        )
    )
    results = future.result()

    # Call multiple functions in a pool and returns values as completed:
    future = as_completed(
        *Procs(3).batch(
            Call(my_func, foo='bar'),
            Call(my_func, foo='baz'),
            Call(my_func, foo='qux'),
        )
    )
    results = future.result()
   
   # etc...

    

Procs().batch(
    Call(myAsyncFunc, arg1),
    Call(mySyncFunc, arg1)
)