from concurrent.futures import ThreadPoolExecutor, as_completed, wait, ALL_COMPLETED


def test(a):
    print(f'一個(gè)假的進(jìn)程任務(wù){(diào)a}')
    return a

def add_thread():
    threads_list = [i for i in range(10)]
    th_executor = ThreadPoolExecutor(max_workers=10)
    for i in threads_list:
        # 線程池執(zhí)行任務(wù)方法1
        th_executor.submit(test, i)
    # 線程池執(zhí)行任務(wù)方法2
    th_executor.map(test, threads_list)

    # 線程池獲取結(jié)果方法1：使用as_completed方法，然后用其result屬性輸出結(jié)果
    all_thread = [th_executor.submit(test, i) for i in threads_list]
    results1 = [j.result() for j in as_completed(all_thread)]
    print('result1結(jié)果:', results1)
	# result1結(jié)果: [3, 0, 2, 4, 1, 5, 6, 8, 9, 7]

    # 線程池獲取結(jié)果方法2
    results2 = [k for k in th_executor.map(test, threads_list)]
    print('results2結(jié)果:', results2)
    # results2結(jié)果: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]

    # 也可以使用等待函數(shù),fs:任務(wù)序列;timeout任務(wù)最大等待時(shí)間,在規(guī)定時(shí)間內(nèi),任務(wù)未執(zhí)行完成也會(huì)停止;
    # return_when:wait返回結(jié)果的條件，默認(rèn)為ALL_COMPLETED,全部執(zhí)行完成再返回
    # 譬如,此處以下的代碼是展示wait的用法
    # task_list = th_executor.map(test, threads_list)
    # 等待任務(wù)完成
    # wait(task_list)
    # 任務(wù)完成之后再進(jìn)行結(jié)果的獲取
    # task_result = [k for k in task_list]


if __name__ == '__main__':

    add_thread()

from concurrent.futures import ProcessPoolExecutor, as_completed, wait, ALL_COMPLETED

def test(a):
    print(f'一個(gè)假的線程任務(wù){(diào)a}')
    return a

def add_process():
    with ProcessPoolExecutor(max_workers=8) as pool:
        process_list = [i for i in range(10)]
        for i in process_list:
            # 進(jìn)程池執(zhí)行任務(wù)方法1
            pool.submit(test, i)
        # 進(jìn)程池執(zhí)行任務(wù)方法2
        pool.map(test, process_list)

        # 進(jìn)程池獲取結(jié)果方法1：使用as_completed方法，然后用其result屬性輸出結(jié)果
        all_process = [pool.submit(test, i) for i in process_list]
        results1 = [j.result() for j in as_completed(all_process)]
        print('result1結(jié)果:', results1)
        # results1結(jié)果: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]

        # 進(jìn)程池獲取結(jié)果方法2
        results2 = [k for k in pool.map(test, process_list)]
        print('results2結(jié)果:', results2)
    	# results2結(jié)果: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9]

        # 也可以使用等待函數(shù),fs:任務(wù)序列;timeout任務(wù)最大等待時(shí)間,在規(guī)定時(shí)間內(nèi),任務(wù)未執(zhí)行完成也會(huì)停止;
        # return_when:wait返回結(jié)果的條件，默認(rèn)為ALL_COMPLETED,全部執(zhí)行完成再返回
        # 譬如,此處是展示wait的用法
        # task_list = pool.map(test, process_list)
        # # 等待任務(wù)完成
        # wait(task_list)
        # # 任務(wù)完成之后再進(jìn)行結(jié)果的獲取
        # task_result = [k for k in task_list]



if __name__ == '__main__':

    add_process()