Python多线程入门教程

import threading
import time
def task(name, delay):
    print(f"{name} 开始")
    time.sleep(delay)
    print(f"{name} 结束")
# 创建线程
t1 = threading.Thread(target=task, args=("任务A", 2))
t2 = threading.Thread(target=task, args=("任务B", 1))
# 启动线程
t1.start()
t2.start()
# 等待线程结束
t1.join()
t2.join()
print("全部完成")

任务A 开始
任务B 开始
任务B 结束
任务A 结束
全部完成

import threading
import requests
urls = [
    "https://api.example.com/1",
    "https://api.example.com/2",
    "https://api.example.com/3",
]
results = []
lock = threading.Lock()  # 保护共享数据
def fetch(url):
    resp = requests.get(url, timeout=5)
    with lock:  # 加锁，避免多个线程同时写列表
        results.append(resp.status_code)
threads = []
for url in urls:
    t = threading.Thread(target=fetch, args=(url,))
    t.start()
    threads.append(t)
for t in threads:
    t.join()
print(f"完成 {len(results)} 个请求")

from concurrent.futures import ThreadPoolExecutor
import requests
urls = ["url1", "url2", "url3", ...]
def fetch(url):
    return requests.get(url).status_code
with ThreadPoolExecutor(max_workers=5) as executor:
    results = list(executor.map(fetch, urls))
print(results)