Python 中进程间通信的方式有哪些？-JavaScript中文网-JavaScript教程资源分享门户

本题详细解读

1. 管道（Pipe）

管道是一种半双工的通信方式，通常用于父子进程之间的通信。Python 的 multiprocessing.Pipe() 返回两个连接对象，分别代表管道的两端。一个进程可以通过 send() 方法发送数据，另一个进程可以通过 recv() 方法接收数据。

// www.javascriptcn.com code example
from multiprocessing import Process, Pipe

def worker(conn):
    conn.send("Hello from worker")
    conn.close()

parent_conn, child_conn = Pipe()
p = Process(target=worker, args=(child_conn,))
p.start()
print(parent_conn.recv())  # 输出: Hello from worker
p.join()

2. 队列（Queue）

队列是一种线程安全的 FIFO 数据结构，允许多个进程之间安全地传递数据。multiprocessing.Queue() 提供了 put() 和 get() 方法，分别用于向队列中添加数据和从队列中获取数据。

// www.javascriptcn.com code example
from multiprocessing import Process, Queue

def worker(q):
    q.put("Hello from worker")

q = Queue()
p = Process(target=worker, args=(q,))
p.start()
print(q.get())  # 输出: Hello from worker
p.join()

3. 共享内存（Shared Memory）

共享内存允许多个进程共享同一块内存区域，适用于需要高效共享数据的场景。multiprocessing.Value 和 multiprocessing.Array 可以用于创建共享内存对象。

// www.javascriptcn.com code example
from multiprocessing import Process, Value, Array

def worker(n, a):
    n.value = 3.1415927
    for i in range(len(a)):
        a[i] = -a[i]

num = Value('d', 0.0)
arr = Array('i', range(10))

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

print(num.value)  # 输出: 3.1415927
print(arr[:])     # 输出: [0, -1, -2, -3, -4, -5, -6, -7, -8, -9]

4. 信号量（Semaphore）

信号量用于控制对共享资源的访问，通常用于同步多个进程。multiprocessing.Semaphore() 提供了 acquire() 和 release() 方法，分别用于获取和释放信号量。

// www.javascriptcn.com code example
from multiprocessing import Process, Semaphore

def worker(sem):
    sem.acquire()
    print("Worker is working")
    sem.release()

sem = Semaphore(1)
p = Process(target=worker, args=(sem,))
p.start()
p.join()

5. 套接字（Socket）

套接字是一种网络通信方式，允许不同机器上的进程进行通信。Python 的 socket 模块提供了创建套接字的功能。

// www.javascriptcn.com code example
import socket

def server():
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind(('localhost', 12345))
    s.listen(1)
    conn, addr = s.accept()
    print('Connected by', addr)
    data = conn.recv(1024)
    print(data.decode())
    conn.close()

def client():
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect(('localhost', 12345))
    s.sendall(b'Hello from client')
    s.close()

from multiprocessing import Process

p1 = Process(target=server)
p2 = Process(target=client)
p1.start()
p2.start()
p1.join()
p2.join()

6. 消息队列（Message Queue）

消息队列是一种高级的进程间通信方式，通常用于分布式系统中。Python 可以通过第三方库如 Redis 或 RabbitMQ 实现消息队列。

// www.javascriptcn.com code example
import redis

def producer():
    r = redis.Redis()
    r.rpush('queue', 'Hello from producer')

def consumer():
    r = redis.Redis()
    msg = r.blpop('queue')
    print(msg[1].decode())

from multiprocessing import Process

p1 = Process(target=producer)
p2 = Process(target=consumer)
p1.start()
p2.start()
p1.join()
p2.join()

7. 文件（File）

文件是一种简单的进程间通信方式，通过读写文件传递数据。虽然效率较低，但在某些场景下仍然适用。

// www.javascriptcn.com code example
def writer():
    with open('data.txt', 'w') as f:
        f.write('Hello from writer')

def reader():
    with open('data.txt', 'r') as f:
        print(f.read())

from multiprocessing import Process

p1 = Process(target=writer)
p2 = Process(target=reader)
p1.start()
p1.join()
p2.start()
p2.join()

Python 中进程间通信的方式有哪些？

推荐答案