python process pool executor

python_process_pool.py

from asyncio import as_completed
from multiprocessing import Pool
import multiprocessing  as mp
from re import X
import re
import time
import concurrent.futures

def xx(a):
    for _ in range(2):
        print(f'a:{a}')
        time.sleep(1)
    return mp.current_process().name

if __name__ == "__main__":
    a=[1,2,3,4,5,6]
    with concurrent.futures.ThreadPoolExecutor(max_workers=3) as ex:
        results=ex.map(xx,a)
        for i in results:
            print(i)