Message388771
Example code (fails):
import os, concurrent.futures
def parallel_callback( arg ):
return os.getpid()
def parallel( *args ):
def thread_callback( param ):
with concurrent.futures.ProcessPoolExecutor(max_workers=1) as executor:
future = executor.submit( parallel_callback, param )
pid = future.result()
print( 'pid:', pid )
return pid
with concurrent.futures.ThreadPoolExecutor(max_workers=len(args)) as executor:
future = executor.map( thread_callback, args )
results = list(future)
print( 'DONE' )
parallel( 1, 2, 3 ) |
|
Date |
User |
Action |
Args |
2021-03-15 19:52:58 | doublex | set | recipients:
+ doublex, ishimoto, drougge, aeros, iritkatriel, cebtenzzre |
2021-03-15 19:52:58 | doublex | set | messageid: <1615837978.77.0.403121171558.issue41567@roundup.psfhosted.org> |
2021-03-15 19:52:58 | doublex | link | issue41567 messages |
2021-03-15 19:52:58 | doublex | create | |
|