import threading
import time

def task(name, seconds):
    print(f"線程 {name} 開始執(zhí)行")
    time.sleep(seconds)
    print(f"線程 {name} 執(zhí)行完畢")

# 創(chuàng)建線程
t1 = threading.Thread(target=task, args=("A", 2))
t2 = threading.Thread(target=task, args=("B", 1))

# 啟動線程
t1.start()
t2.start()

# 等待線程結(jié)束
t1.join()
t2.join()

print("所有線程執(zhí)行完畢")

import threading
import time

class MyThread(threading.Thread):
    def __init__(self, name):
        super().__init__()
        self.name = name
    
    def run(self):
        print(f"線程 {self.name} 開始")
        time.sleep(2)
        print(f"線程 {self.name} 結(jié)束")

t = MyThread("自定義線程")
t.start()
t.join()

import threading

balance = 0
lock = threading.Lock()

def deposit():
    global balance
    for _ in range(100000):
        lock.acquire()  # 加鎖
        try:
            balance += 1
        finally:
            lock.release()  # 解鎖

t1 = threading.Thread(target=deposit)
t2 = threading.Thread(target=deposit)

t1.start()
t2.start()
t1.join()
t2.join()

print(f"最終余額: {balance}")  # 正確輸出 200000

# 去掉 lock，結(jié)果可能是 199847（數(shù)據(jù)不一致）

from concurrent.futures import ThreadPoolExecutor
import time

def task(n):
    print(f"任務(wù) {n} 開始")
    time.sleep(1)
    return f"任務(wù) {n} 完成"

# 創(chuàng)建線程池（最多5個線程）
with ThreadPoolExecutor(max_workers=5) as executor:
    # 提交10個任務(wù)
    futures = [executor.submit(task, i) for i in range(10)]
    
    # 獲取結(jié)果
    for future in futures:
        print(future.result())

import threading
import requests
from concurrent.futures import ThreadPoolExecutor

def download_image(url):
    try:
        response = requests.get(url, timeout=10)
        filename = url.split("/")[-1]
        with open(filename, "wb") as f:
            f.write(response.content)
        print(f"? 下載完成: {filename}")
    except Exception as e:
        print(f"? 下載失敗: {url}, 錯誤: {e}")

urls = [
    "https://example.com/image1.jpg",
    "https://example.com/image2.jpg",
    "https://example.com/image3.jpg",
]

# 使用線程池并發(fā)下載
with ThreadPoolExecutor(max_workers=3) as executor:
    executor.map(download_image, urls)