Lære 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()

Alt var klart?

Takk for tilbakemeldingene dine!

Seksjon 3. Kapittel 2

Spør AI

Spør om hva du vil, eller prøv ett av de foreslåtte spørsmålene for å starte chatten vår

Sveip for å vise menyen


              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()

Alt var klart?

Takk for tilbakemeldingene dine!

Seksjon 3. Kapittel 2