how to async call a processpoolexecutor?

[DeoLeung]

I have some large model would like to initialize and run in process pool(without auto close the process)

I can do

import asyncio
pool = ProcessPoolExecutor(max_workers=2, initializer=create_model)

loop = asyncio.get_event_loop()
await loop.run_in_executor(pool, do_something)

is there something similar in anyio? from the to_process module I didn't find how to pass in the pool

[agronholm]

You should use to_process.run_sync(). You can't pass an existing synchronous process pool to this function.