在多线程编程中，线程间通信机制包括：共享内存、锁、事件、信号量和消息队列。1. 共享内存：通过共享变量实现数据交换。2. 锁：通过同步机制防止数据竞争和死锁。3. 事件：允许线程等待特定事件发生。4. 信号量：限制访问共享资源的线程数量。5. 消息队列：实现线程间安全的消息交换。

多线程编程中不同线程间通信

在多线程编程中，不同线程之间的通信是至关重要的，它使线程能够共享数据和同步操作。这里介绍几种常用的通信机制：

1. 共享内存

通过共享变量或数据结构，不同线程可以读写同一块内存区域，实现数据交换。

# 创建一个共享变量
shared_variable = 0

# 线程1
def increment_shared_variable():
    global shared_variable
    shared_variable += 1

# 线程2
def decrement_shared_variable():
    global shared_variable
    shared_variable -= 1

# 启动线程
import threading
t1 = threading.Thread(target=increment_shared_variable)
t2 = threading.Thread(target=decrement_shared_variable)
t1.start()
t2.start()

# 等待线程完成
t1.join()
t2.join()

# 打印共享变量的最终值
print(shared_variable)  # 输出：0

2. 锁

锁是一种同步机制，它允许一次只允许一个线程访问共享资源。这可以防止数据竞争和死锁。

macOS UI 自动化技能包 —— 用 Python 控制你的 Mac

让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac，无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启：辅助功能 + 屏幕录制权限

下载

import threading

# 创建一个锁
lock = threading.Lock()

# 线程1
def access_shared_resource():
    with lock:
        # 在该代码块内，只有当前线程可以访问共享资源

# 线程2
def access_shared_resource_2():
    with lock:
        # 只有线程1释放锁后，线程2才能访问共享资源

# 启动线程
t1 = threading.Thread(target=access_shared_resource)
t2 = threading.Thread(target=access_shared_resource_2)
t1.start()
t2.start()

# 等待线程完成
t1.join()
t2.join()

3. 事件

事件是一种同步机制，它允许一个线程等待另一个线程完成特定事件。

import threading

# 创建一个事件
event = threading.Event()

# 线程1
def do_something():
    # 执行一些操作
    event.set()  # 事件发生

# 线程2
def wait_for_event():
    event.wait()  # 等待事件发生

# 启动线程
t1 = threading.Thread(target=do_something)
t2 = threading.Thread(target=wait_for_event)
t1.start()
t2.start()

# 等待线程完成
t1.join()
t2.join()

4. 信号量

信号量是一种同步机制，它限制同时访问共享资源的线程数量。

import threading

# 创建一个信号量
semaphore = threading.Semaphore(3)  # 允许最多 3 个线程同时访问资源

# 线程1
def access_shared_resource():
    with semaphore:
        # 只有当信号量可用时，才能访问共享资源

# 启动多个线程
threads = []
for i in range(10):
    t = threading.Thread(target=access_shared_resource)
    threads.append(t)
    t.start()

# 等待线程完成
for t in threads:
    t.join()

5. 消息队列

消息队列是一种通信机制，允许线程安全地交换消息。

import queue

# 创建一个消息队列
queue = queue.Queue()

# 线程1
def producer():
    queue.put("Hello, world!")

# 线程2
def consumer():
    message = queue.get()  # 等待并获取消息

# 启动线程
t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer)
t1.start()
t2.start()

# 等待线程完成
t1.join()
t2.join()