1.多线程
from threading import Thread
示例1
from threading import Thread
def func1(name):
for i in range(1000):
print("func1", i)
def func2(name):
for i in range(1000):
print("func2", i)
if __name__ == "__main__": # args 传递参数, 元组
t1 = Thread(target=func1, args=("测试",))
t1.start()
t2 = Thread(target=func2, args=("测试",))
t2.start()
示例2
from threading import Thread
class MyThread(Thread):
def run(self): # 固定的
for i in range(1000):
print("子", i)
# 构造函数传参
if __name__ == "__main__":
t = MyThread()
t.start() # 默认执行run
for i in range(1000):
print("主", i)
2.多进程
from multiprocessing import Process
from multiprocessing import Process
def func():
for i in range(1000):
print("子进程", i)
if __name__ == "__main__":
p = Process(target=func)
p.start()
for i in range(1000):
print("主进程", i)
3.线程池
一次性开辟一些线程， 用户直接给线程池提交任务。线程任务的调度交给线程池来完成
from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
def fun(name):
for i in range(1000):
print(name, i)
if __name__ == "__main__":
#
with ThreadPoolExecutor(50) as t: # 创建线程池, 50 个线程
for i in range(100):
t.submit(fun, name=f"线程{i}")
# 等线程池中的任务结束，才执行
print("结束")
4.进程池( 与线程池只修改了 with 后的类名)
from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
def fun(name):
for i in range(1000):
print(name, i)
if __name__ == "__main__":
#
with ProcessPoolExecutor(50) as t: # 创建进程池, 50 个线程
for i in range(100):
t.submit(fun, name=f"进程{i}")
# 等线程池中的任务结束，才执行
print("结束")