Python：threading 库高级用法举例和应用详解

import threading  # 导入threading库
import time  # 导入time库，用于模拟耗时操作

def print_numbers():  # 定义线程要执行的函数
    for i in range(5):
        print(f"Number: {i}")
        time.sleep(1)  # 模拟耗时操作，暂停1秒

# 创建线程对象，目标函数为print_numbers
thread = threading.Thread(target=print_numbers)
thread.start()  # 启动线程

# 主线程继续执行其他操作
for i in range(5, 10):
    print(f"Main Thread Number: {i}")
    time.sleep(1)  # 模拟耗时操作，暂停1秒

# 等待子线程执行完成
thread.join()
print("子线程执行完成")

import threading  # 导入threading库
import time  # 导入time库，用于模拟耗时操作

class SharedCounter:
    def __init__(self):
        self.counter = 0
        self.lock = threading.Lock()  # 创建一个锁对象

    def increment(self):
        with self.lock:  # 使用with上下文管理器简化锁的获取与释放
            self.counter += 1
            print(f"Counter: {self.counter}")
            time.sleep(0.5)  # 模拟耗时操作

counter = SharedCounter()  # 初始化共享计数器

def worker():
    for _ in range(5):
        counter.increment()

threads = []
for i in range(2):  # 创建两个线程
    thread = threading.Thread(target=worker)
    threads.append(thread)
    thread.start()

# 等待所有子线程完成
for thread in threads:
    thread.join()
print("所有线程执行完成")

import threading  # 导入threading库
import queue  # 导入queue库，用于线程间通信
import time  # 导入time库，用于模拟耗时操作

def producer(q):
    for i in range(5):
        item = f"item {i}"
        q.put(item)  # 将项目放入队列
        print(f"Produced {item}")
        time.sleep(1)  # 模拟耗时操作

def consumer(q):
    while True:
        item = q.get()  # 从队列中获取项目
        if item is None:  # 当接收到None时，表示生产结束
            break
        print(f"Consumed {item}")
        q.task_done()  # 通知队列任务完成
        time.sleep(1)  # 模拟耗时操作

q = queue.Queue()  # 创建线程安全的队列

# 创建生产者和消费者线程
producer_thread = threading.Thread(target=producer, args=(q,))
consumer_thread = threading.Thread(target=consumer, args=(q,))

# 启动线程
producer_thread.start()
consumer_thread.start()

# 等待生产者线程完成
producer_thread.join()

# 添加None到队列，表示生产结束
q.put(None)
q.join()  # 等待所有任务完成
consumer_thread.join()  # 等待消费者线程完成
print("生产消费者模式执行完成")