在python中将连接对象从进程传递到主进程

from multiprocessing import Process, Queue

def worker(queue):
    conn = queue.get()
    # 在子进程中使用连接对象

if __name__ == '__main__':
    queue = Queue()
    # 创建连接对象
    conn = create_connection()
    # 将连接对象放入队列
    queue.put(conn)

    p = Process(target=worker, args=(queue,))
    p.start()
    p.join()

from multiprocessing import Process, Pipe

def worker(conn):
    conn.send(conn)
    # 在子进程中使用连接对象

if __name__ == '__main__':
    parent_conn, child_conn = Pipe()
    # 创建连接对象
    conn = create_connection()
    # 将连接对象传递给子进程
    p = Process(target=worker, args=(child_conn,))
    p.start()

    conn = parent_conn.recv()
    # 在主进程中使用连接对象

    p.join()

from multiprocessing import Process, Manager

def worker(conn):
    # 在子进程中使用连接对象

if __name__ == '__main__':
    with Manager() as manager:
        # 创建连接对象
        conn = create_connection()
        # 将连接对象共享给子进程
        p = Process(target=worker, args=(manager.list([conn]),))
        p.start()

        conn = manager.list()[0]
        # 在主进程中使用连接对象

        p.join()