python 线程池与进程池简单实现

本文主要是介绍python 线程池与进程池简单实现，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

import time
import random
from concurrent.futures import ThreadPoolExecutor
from multiprocessing import Process, Pool

def worker(n, index):
    print('开始第{}个进程，第{}个线程'.format(n, index))
    t = random.random()
    time.sleep(t)
    print('结束第{}个进程，第{}个线程'.format(n, index))

def main(n):
    max_workers = 20 # 最大线程数
    pool = ThreadPoolExecutor(max_workers=max_workers, thread_name_prefix='Thread')
    i = 0
    while True:
        pool.submit(worker, n, i)
        i = i + 1

if __name__ == "__main__":
    pool1 = Pool(2) # 最大进程数2
    for i in range(1,3):
       pool1.apply_async(main, args=(i, ))
    pool1.close()
    pool1.join()

这篇关于python 线程池与进程池简单实现的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！