Python多处理-如何实现共享计数器和队列

from multiprocessing import Process, Value

def increment(counter, amount):
    with counter.get_lock():
        counter.value += amount

if __name__ == "__main__":
    counter = Value('i', 0)  # 'i'表示整数类型，初始值为0
    processes = [Process(target=increment, args=(counter, 1)) for _ in range(10)]

    for p in processes:
        p.start()
    for p in processes:
        p.join()

    print(f"Final counter value: {counter.value}")

from multiprocessing import Process, Queue

def producer(queue):
    for i in range(5):
        queue.put(i)
        print(f"Produced: {i}")

def consumer(queue):
    while True:
        item = queue.get()
        if item is None:  # Sentinel value to indicate end of production
            break
        print(f"Consumed: {item}")

if __name__ == "__main__":
    queue = Queue()
    producer_process = Process(target=producer, args=(queue,))
    consumer_process = Process(target=consumer, args=(queue,))

    producer_process.start()
    consumer_process.start()

    producer_process.join()
    queue.put(None)  # Send sentinel value to indicate end of production
    consumer_process.join()