多线程使用中介者模式

在多线程编程中，中介者模式可以用于协调和管理不同线程之间的通信和交互。中介者模式通过引入一个中介对象来减少线程之间的直接依赖，从而提高代码的可维护性和扩展性。

中介者模式的核心思想是，将各个线程之间的通信逻辑封装到一个中介者对象中，线程可以通过与中介者对象进行交互，而不需要了解其他线程的具体实现细节。中介者对象负责处理线程之间的消息传递、协调和同步操作。

下面是一个简单的示例代码，演示了如何在多线程程序中使用中介者模式：

import threading

class Mediator:
    def __init__(self):
        self.thread_a = ThreadA(self)
        self.thread_b = ThreadB(self)

    def start(self):
        self.thread_a.start()
        self.thread_b.start()

    def send_message_from_a_to_b(self, message):
        self.thread_b.receive_message(message)

    def send_message_from_b_to_a(self, message):
        self.thread_a.receive_message(message)

class ThreadA(threading.Thread):
    def __init__(self, mediator):
        super().__init__()
        self.mediator = mediator

    def run(self):
        # 线程A执行的逻辑
        message = "Hello from Thread A"
        self.mediator.send_message_from_a_to_b(message)

    def receive_message(self, message):
        print("Thread A received:", message)

class ThreadB(threading.Thread):
    def __init__(self, mediator):
        super().__init__()
        self.mediator = mediator

    def run(self):
        # 线程B执行的逻辑
        message = "Hello from Thread B"
        self.mediator.send_message_from_b_to_a(message)

    def receive_message(self, message):
        print("Thread B received:", message)

# 主线程作为中介者
mediator = Mediator()

# 启动线程
mediator.start()

在上述示例中，Mediator类充当中介者对象，它拥有两个线程对象thread_a和thread_b。线程A和线程B都持有对中介者对象的引用，并通过调用中介者对象的方法来进行通信。

当线程A运行时，它会将消息发送给中介者对象，中介者对象再将消息传递给线程B。线程B收到消息后打印出来。同样地，当线程B运行时，它也会将消息发送给中介者对象，中介者对象再将消息传递给线程A。

使用中介者模式可以很好地解耦多线程程序中的各个线程，提高代码的可维护性和可扩展性。同时，中介者模式也可以帮助我们管理线程之间的同步问题，确保线程之间的顺序和正确性。