from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor def fn(name): for i in range(1000): print(name,i) if __name__ == '__main__': with ThreadPoolExecutor(10) as t: for i in range(100): t.submit(fn,name=f"线程{i}") with ProcessPoolExecutor(10) as t: for i in range(100): t.submit(fn,name=f"进程{i}")
这段 Python 代码主要使用了 concurrent.futures 模块中的 ThreadPoolExecutor (线程池)和 ProcessPoolExecutor (进程池)来并发执行任务。
在 ThreadPoolExecutor 部分,创建了一个最大线程数为 10 的线程池,并通过循环向线程池中提交了 100 个任务,每个任务都是调用 fn 函数并传递一个名称参数。
在 ProcessPoolExecutor 部分,创建了一个最大进程数为 10 的进程池,同样通过循环提交了 100 个任务。
由于线程和进程的并发执行,输出会比较混乱,线程和进程的执行顺序是不确定的,这取决于操作系统的调度。您是对这段代码的运行机制有疑问,还是在运行时遇到了错误呢?