菜鸟IT的博客 >> Python
设置动态的最大线程数,限制函数在多线程下最大线程数,示范
import multiprocessing
import threading
CpuHeNum=multiprocessing.cpu_count()
print("CPU核心数:",CpuHeNum)
# 提前定义多线程的最大线程数(如果是输入输出IO密集型)
MaxXianChengNum = threading.Semaphore(CpuHeNum*2) # 限制线程的最大数量为2倍cpu核心数
# 然后对应的函数这样弄
def DoSomething(j):
with MaxXianChengNum: # 限定该函数被多线程运行时的最大线程数
print("开始我的任务...",j)
# for循环开启多线程
for i in range(1,100+1):
Input_Thread = threading.Thread(target=Get_PageN_All_Proxies_IP, args=(i,))
Input_Thread.start()
菜鸟IT博客[2022.05.08-19:46] 访问:322