关于线程池包concurrent的简单使用

concurrent是一个并发的线程池包，再平时的工作，如果使用多线程同时使用的话，可以用到这个包，比较简单粗暴，直接上代码看下。

from concurrent.futures import ThreadPoolExecutor
import time
def sum(num):
    s = num+10
    print('sum'.format(s))
    time.sleep(4)
    return s
def sum2(num,num2):
    s = num+num2
    print('sum2'.format(s))
    time.sleep(50)
    return s
def cheng(num1,num2):
    s = num1*num2
    print('cheng'.format(s))
    time.sleep(2)
    return s

thread_pool = ThreadPoolExecutor(4)  # 定义2个线程执行此任务
num_list = [0,1,2,3,4,5,6,7,8,9]
for num in num_list:
    thread_pool.submit(sum,num)
    thread_pool.submit(sum2,num,num)


thread_pool = ThreadPoolExecutor(2)  # 定义2个线程执行此任务
num_list = [0,1,2,3,4,5,6,7,8,9]
for num in num_list:
    thread_pool.submit(cheng,num,num)

最后修改:2021-09-27 17:30:21