使用BaseManager()实现进程间共享队列与通信

进程间通信（Inter-process communication，IPC）是指在一个计算机系统中，不同进程之间传输数据或者协调行为的机制。Python中的multiprocessing模块提供了一些用于进程间通信的类和函数，其中之一就是BaseManager。

BaseManager是一个基类，它提供了一个可以用于创建可在多个进程之间共享的Python对象的方法。具体来说，BaseManager提供了一个register方法，用于将一个python类型注册为可在多个进程间共享的类型。在注册之后，我们就可以通过创建一个Manager对象来实例化被注册的类型的实例，并在多个进程之间进行共享。

下面我们来看一个使用BaseManager进行进程间共享队列与通信的例子：

from multiprocessing import Process, Queue
from multiprocessing.managers import BaseManager

# 定义一个可在多个进程之间共享的列表类型
class SharedQueueManager(BaseManager):
    pass

# 注册共享的Queue类型
SharedQueueManager.register('Queue', Queue)

def worker(queue):
    print('Worker process started')
    # 从队列中读取数据
    data = queue.get()
    print('Worker received:', data)
    # 向队列中写入数据
    queue.put('Hello from worker')

if __name__ == '__main__':
    print('Main process started')

    # 创建一个Manager对象
    manager = SharedQueueManager()
    manager.start()

    # 通过Manager对象创建一个共享的Queue实例
    queue = manager.Queue()

    # 创建一个进程，并将共享的Queue传递给进程
    p = Process(target=worker, args=(queue,))
    p.start()

    # 向共享的Queue中写入数据
    queue.put('Hello from main')

    # 等待子进程结束
    p.join()

    # 从共享的Queue中读取数据
    data = queue.get()
    print('Main received:', data)

    # 关闭Manager对象
    manager.shutdown()
    print('Main process ended')

在这个例子中，我们首先定义了一个继承自BaseManager的类SharedQueueManager。然后我们通过调用register方法，将Queue类型注册为可在多个进程间共享的类型。接下来，在主进程中，我们创建了一个SharedQueueManager对象，并通过调用start方法启动这个Manager对象。

然后，我们通过Manager对象的Queue方法创建了一个共享的队列实例。在主进程中，我们创建了一个子进程，并将共享的队列实例作为参数传递给子进程。在子进程中，我们先从队列中读取数据，然后向队列中写入数据，并在最后结束进程。

在主进程中，我们也向队列中写入数据，并等待子进程结束。然后，我们从共享的队列中读取数据，并在控制台输出结果。最后，我们通过调用manager对象的shutdown方法关闭Manager对象。

通过使用BaseManager，我们可以方便地实现进程间的通信和数据共享。在这个例子中，我们使用了共享的队列作为通信的工具，但实际上，我们也可以使用共享的列表、字典等数据类型来实现进程间的数据共享。这样，不同的进程可以同时读写数据，从而实现更为灵活和高效的进程间通信。