Python多进程加锁的实现

import multiprocessing
lock = multiprocessing.Lock()
def func():
    lock.acquire()
    #执行需要互斥保护的代码
    lock.release()

import multiprocessing
lock = multiprocessing.Lock()
def func():
    with lock:
        #执行需要互斥保护的代码

import multiprocessing
def func(queue):
    #向队列中写入数据
    queue.put("hello")
if __name__ == "__main__":
    queue = multiprocessing.Queue()
    p = multiprocessing.Process(target=func, args=(queue,))
    p.start()
    #从队列中读取数据
    data = queue.get()
    p.join()

import multiprocessing
def func(lock, queue):
    with lock:
        #向队列中写入数据
        queue.put("hello")
if __name__ == "__main__":
    lock = multiprocessing.Lock()
    queue = multiprocessing.Queue()
    pool = multiprocessing.Pool()
    for i in range(10):
        pool.apply_async(func, args=(lock, queue,))
    pool.close()
    pool.join()
    #从队列中读取数据
    data_list = []
    while not queue.empty():
        data_list.append(queue.get())

import multiprocessing
def func(num):
    num.value += 1
if __name__ == "__main__":
    num = multiprocessing.Value("i", 0)
    process_list = []
    for i in range(10):
        p = multiprocessing.Process(target=func, args=(num,))
        process_list.append(p)
        p.start()
    for p in process_list:
        p.join()
    print(num.value)

import multiprocessing
def func(arr):
    for i in range(len(arr)):
        arr[i] += 1
if __name__ == "__main__":
    arr = multiprocessing.Array("i", [0, 1, 2, 3, 4, 5, 6, 7, 8, 9])
    process_list = []
    for i in range(10):
        p = multiprocessing.Process(target=func, args=(arr,))
        process_list.append(p)
        p.start()
    for p in process_list:
        p.join()
    print(arr[:])