import threading
import time

def print_numbers():
    for i in range(1, 6):
        print(i)
        time.sleep(1)

# 創(chuàng)建線程
thread = threading.Thread(target=print_numbers)

# 啟動(dòng)線程
thread.start()

# 主線程等待子線程執(zhí)行完成
thread.join()

print("線程執(zhí)行完成！")

import threading
import time

# 全局標(biāo)志位，控制線程執(zhí)行
is_running = True

def count_numbers():
    i = 1
    while is_running:
        print(i)
        i += 1
        time.sleep(1)

# 創(chuàng)建線程
thread = threading.Thread(target=count_numbers)

# 啟動(dòng)線程
thread.start()

# 主線程等待一段時(shí)間后修改標(biāo)志位，結(jié)束線程
time.sleep(5)
is_running = False

print("等待線程執(zhí)行完成...")
thread.join()

print("線程執(zhí)行完成！")

import threading
import time

# 創(chuàng)建 Event 對象
stop_event = threading.Event()

def count_numbers():
    i = 1
    while not stop_event.is_set():
        print(i)
        i += 1
        time.sleep(1)

# 創(chuàng)建線程
thread = threading.Thread(target=count_numbers)

# 啟動(dòng)線程
thread.start()

# 主線程等待一段時(shí)間后設(shè)置 Event，結(jié)束線程
time.sleep(5)
stop_event.set()

print("等待線程執(zhí)行完成...")
thread.join()

print("線程執(zhí)行完成！")

import threading
import time

def task():
    try:
        # 這里是線程執(zhí)行的任務(wù)
        print("任務(wù)開始...")
        time.sleep(3)
        raise Exception("人為拋出異常")
    except Exception as e:
        print(f"捕獲到異常：{e}")

# 創(chuàng)建線程
thread = threading.Thread(target=task)

# 啟動(dòng)線程
thread.start()

# 主線程等待線程執(zhí)行完成
thread.join()

print("線程執(zhí)行完成！")

from concurrent.futures import ThreadPoolExecutor
import time

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

# 創(chuàng)建線程池
with ThreadPoolExecutor(max_workers=3) as executor:
    # 提交任務(wù)給線程池執(zhí)行
    for i in range(1, 6):
        executor.submit(task, i)

print("所有任務(wù)執(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} 線程開始執(zhí)行...")
        time.sleep(3)
        print(f"{self.name} 線程執(zhí)行完成！")

# 創(chuàng)建線程實(shí)例并啟動(dòng)
thread1 = MyThread("Thread 1")
thread2 = MyThread("Thread 2")

thread1.start()
thread2.start()

# 等待線程執(zhí)行完成
thread1.join()
thread2.join()

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

import threading

shared_resource = 0
lock = threading.Lock()

def update_shared_resource():
    global shared_resource
    for _ in range(100000):
        lock.acquire()
        shared_resource += 1
        lock.release()

# 創(chuàng)建多個(gè)線程來更新共享資源
threads = []
for _ in range(5):
    t = threading.Thread(target=update_shared_resource)
    threads.append(t)
    t.start()

# 等待所有線程執(zhí)行完成
for t in threads:
    t.join()

print("共享資源的值為:", shared_resource)

import threading
import time

MAX_ITEMS = 5
items = []
condition = threading.Condition()

def producer():
    for i in range(10):
        time.sleep(1)
        with condition:
            if len(items) >= MAX_ITEMS:
                print("倉庫已滿，生產(chǎn)者等待...")
                condition.wait()
            print("生產(chǎn)者生產(chǎn)一個(gè)商品")
            items.append(i)
            condition.notify()

def consumer():
    for i in range(10):
        time.sleep(1.5)
        with condition:
            while not items:
                print("倉庫為空，消費(fèi)者等待...")
                condition.wait()
            item = items.pop(0)
            print(f"消費(fèi)者消費(fèi)了商品 {item}")
            condition.notify()

# 創(chuàng)建生產(chǎn)者和消費(fèi)者線程并啟動(dòng)
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)

producer_thread.start()
consumer_thread.start()

# 等待線程執(zhí)行完成
producer_thread.join()
consumer_thread.join()

print("所有商品已被生產(chǎn)和消費(fèi)完畢！")

import threading
import queue
import time

MAX_ITEMS = 5
queue = queue.Queue(MAX_ITEMS)

def producer():
    for i in range(10):
        time.sleep(1)
        try:
            queue.put(i, block=True, timeout=1)
            print("生產(chǎn)者生產(chǎn)一個(gè)商品")
        except queue.Full:
            print("倉庫已滿，生產(chǎn)者等待...")

def consumer():
    for i in range(10):
        time.sleep(1.5)
        try:
            item = queue.get(block=True, timeout=1)
            print(f"消費(fèi)者消費(fèi)了商品 {item}")
        except queue.Empty:
            print("倉庫為空，消費(fèi)者等待...")

# 創(chuàng)建生產(chǎn)者和消費(fèi)者線程并啟動(dòng)
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)

producer_thread.start()
consumer_thread.start()

# 等待線程執(zhí)行完成
producer_thread.join()
consumer_thread.join()

print("所有商品已被生產(chǎn)和消費(fèi)完畢！")

import threading
import time

def task():
    print("線程開始執(zhí)行...")
    time.sleep(3)  # 模擬線程執(zhí)行時(shí)間
    print("線程執(zhí)行完成！")

# 創(chuàng)建線程
thread = threading.Thread(target=task)

# 啟動(dòng)線程
thread.start()

# 定時(shí)器，3秒后設(shè)置線程結(jié)束標(biāo)志
def set_thread_finished():
    print("定時(shí)器觸發(fā)，設(shè)置線程結(jié)束標(biāo)志...")
    thread.finished = True

timer = threading.Timer(3, set_thread_finished)
timer.start()

# 主線程等待線程執(zhí)行完成
thread.join()

print("線程執(zhí)行完成！")

import threading
import time

# 創(chuàng)建 Event 對象
event = threading.Event()

def task():
    print("線程開始執(zhí)行...")
    event.wait(3)  # 等待事件觸發(fā)，超時(shí)時(shí)間為3秒
    if event.is_set():
        print("事件被觸發(fā)，線程執(zhí)行完成！")
    else:
        print("超時(shí)退出，線程執(zhí)行未完成！")

# 創(chuàng)建線程
thread = threading.Thread(target=task)

# 啟動(dòng)線程
thread.start()

# 等待一段時(shí)間后設(shè)置事件
time.sleep(2)
print("等待2秒后設(shè)置事件...")
event.set()

# 主線程等待線程執(zhí)行完成
thread.join()

print("線程執(zhí)行完成！")