在linux C中，訊息佇列可以通過key來建立，在使用某個佇列時，可根據key來獲取佇列，進而進行資料的收發；且佇列的前4個位元組，可用於判斷目標程序，不匹配則不接收，也就是多個程序可共用一個佇列進行訊息的收發。

在python中則不同，沒有key，直接get接收。這就要求每個佇列對應一個程序。可對queues.Queue進行一次繼承，新增需要的一些資訊，再建立自己的佇列；為使用方便，可為每個佇列寫一個收發函式。

from multiprocessing import queues


class VQueue(queues.Queue):
    """新增類說明"""
    def __init__(self, qid, name, size, ctx):
        """
        定製自己的訊息佇列
        :param qid: 佇列ID
        :param name: 佇列名稱
        :param size: 佇列大小
        :param ctx: 上下文
        """
        super().__init__(maxsize=size, ctx=ctx)
        if not isinstance(qid, int):
            raise TypeError('Process id must be int type')
        if not isinstance(name, str):
            raise TypeError('Process name must be str type')
        self.qid = qid
        self.name = name

    def __str__(self):
        """返回程序名字"""
        return self.name
 

import multiprocessing

from vv_lib.vv_queue.vqueue import VQueue

# 佇列編號、名稱、大小
queue_def = ((1, 'college queue', 20),
             (2, 'student queue', 20))


class MyQueues():
    def __init__(self):
        self.queues = []
        context = multiprocessing.get_context('spawn')
        for q in queue_def:
            self.queues.append(VQueue(q[0], q[1], q[2], context))


    # 每新增一個佇列，新增一對send、recv方法
    # 向佇列傳送訊息
    def ipc_snd_to_college(self, data):
        self.queues[0].put(data)


    # 從佇列接收訊息
    def ipc_rcv_from_college(self):
        return self.queues[0].get()


    # 向佇列傳送訊息
    def ipc_snd_to_student(self, data):
        self.queues[1].put(data)


    # 從佇列接收訊息
    def ipc_rcv_from_student(self):
        return self.queues[1].get()


class MyGlobal():
    def __init__(self):
        self.queues = MyQueues()