Python 多进程操作同一个对列加锁

在 Python 中，可以使用 `multiprocessing` 模块来实现多进程操作同一个队列加锁。具体步骤如下：

1. 导入 `multiprocessing` 和 `queue` 模块：

import multiprocessing
import queue

2. 创建一个队列和一个锁对象：

queue = multiprocessing.Queue()
lock = multiprocessing.Lock()

3. 定义一个函数，用来往队列中添加数据。在函数中使用锁对象来保证多进程访问队列时的数据安全：

def add_data(data):
    lock.acquire()
    queue.put(data)
    lock.release()

4. 定义一个函数，用来从队列中取出数据。在函数中同样使用锁对象来保证多进程访问队列时的数据安全：

def get_data():
    lock.acquire()
    data = queue.get()
    lock.release()
    return data

5. 创建两个进程，一个用来往队列中添加数据，另一个用来从队列中取出数据：

p1 = multiprocessing.Process(target=add_data, args=('data1',))
p2 = multiprocessing.Process(target=get_data)

6. 启动进程：

p1.start()
p2.start()

7. 等待进程结束：

p1.join()
p2.join()

完整代码示例：

import multiprocessing
import queue

queue = multiprocessing.Queue()
lock = multiprocessing.Lock()

def add_data(data):
    lock.acquire()
    queue.put(data)
    lock.release()

def get_data():
    lock.acquire()
    data = queue.get()
    lock.release()
    return data

p1 = multiprocessing.Process(target=add_data, args=('data1',))
p2 = multiprocessing.Process(target=get_data)

p1.start()
p2.start()

p1.join()
p2.join()