Lära Inter-Process Communication (IPC)

When you run multiple processes in Python, each process runs in its own memory space. This means that, unlike threads, processes cannot directly share variables or objects. If you want to exchange data between processes, you need special tools designed for inter-process communication (IPC). One of the most convenient IPC mechanisms in Python is the multiprocessing.Queue. This queue allows you to safely send data from one process to another, handling all the necessary synchronization and serialization behind the scenes. Using a queue, you can implement patterns like producer-consumer, where one process generates data and another consumes it, without worrying about data corruption or race conditions.


              12345678910111213141516171819
            
from multiprocessing import Process, Queue

def producer(q):
    for i in range(5):
        q.put(f"Message {i}")

def consumer(q):
    while not q.empty():
        msg = q.get()
        print(f"Consumed: {msg}")

if __name__ == "__main__":
    q = Queue()
    p1 = Process(target=producer, args=(q,))
    p2 = Process(target=consumer, args=(q,))
    p1.start()
    p1.join()  # Wait for producer to finish
    p2.start()
    p2.join()

Var allt tydligt?

Tack för dina kommentarer!

Avsnitt 3. Kapitel 2

Fråga AI

Fråga vad du vill eller prova någon av de föreslagna frågorna för att starta vårt samtal

Svep för att visa menyn


              12345678910111213141516171819
            
from multiprocessing import Process, Queue

def producer(q):
    for i in range(5):
        q.put(f"Message {i}")

def consumer(q):
    while not q.empty():
        msg = q.get()
        print(f"Consumed: {msg}")

if __name__ == "__main__":
    q = Queue()
    p1 = Process(target=producer, args=(q,))
    p2 = Process(target=consumer, args=(q,))
    p1.start()
    p1.join()  # Wait for producer to finish
    p2.start()
    p2.join()

Var allt tydligt?

Tack för dina kommentarer!

Avsnitt 3. Kapitel 2