import threading
import time
import requests
threadingnum = 10 # 线程数
def todo_message(tid):
while True:
print(f'线程 {tid} 执行开始')
try:
# 设置超时,避免 requests 卡死
# 如果你后面用 requests,请务必给 timeout
# 示例:
# r = requests.post(url, data=payload, timeout=(3,10))
print('执行内容已经省略')
except Exception as e:
print(f'线程 {tid} 异常:{str(e)}')
# 防止 CPU 100% + 给系统缓冲时间
time.sleep(0.01) # <-- 极小 sleep,避免线程锁死 & 保持流畅
ts = []
for i in range(threadingnum):
t = threading.Thread(target=todo_message, args=(i,), daemon=True)
t.start()
ts.append(t)
print('START')
# 主线程进入休眠,不阻塞、不断线
# 不使用 join(),因为你的线程是无限循环,join 永远无法结束
while True:
time.sleep(1)