آموزش ماژول multiprocessing – انواع روش‌های ارتباط Process‌ها

from multiprocessing import Process, Queue

def producer(queue):
    for i in range(5):
        queue.put(i)
    queue.put(None)          # sentinel: signals end of data

def consumer(queue):
    while True:
        item = queue.get()
        if item is None:
            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()
    consumer_process.join()

from multiprocessing import Process, Queue

def producer(queue):
    for i in range(5):
        queue.put(i)
    queue.put(None)          # sentinel: signals end of data

def consumer(queue):
    while True:
        item = queue.get()
        if item is None:
            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()
    consumer_process.join()

from multiprocessing import Process, Queue

def worker(task_queue, result_queue):
    while True:
        job = task_queue.get()
        if job is None:
            break
        result_queue.put((job, job * job))   # pretend this is heavy CPU work

if __name__ == "__main__":
    task_queue = Queue()
    result_queue = Queue()

    jobs = range(10)
    for j in jobs:
        task_queue.put(j)

    workers = [Process(target=worker, args=(task_queue, result_queue)) for _ in range(3)]
    for w in workers:
        task_queue.put(None)      # one stop signal per worker
    for w in workers:
        w.start()
    for w in workers:
        w.join()

    while not result_queue.empty():
        print(result_queue.get())

from multiprocessing import Process, Queue

def worker(task_queue, result_queue):
    while True:
        job = task_queue.get()
        if job is None:
            break
        result_queue.put((job, job * job))   # pretend this is heavy CPU work

if __name__ == "__main__":
    task_queue = Queue()
    result_queue = Queue()

    jobs = range(10)
    for j in jobs:
        task_queue.put(j)

    workers = [Process(target=worker, args=(task_queue, result_queue)) for _ in range(3)]
    for w in workers:
        task_queue.put(None)      # one stop signal per worker
    for w in workers:
        w.start()
    for w in workers:
        w.join()

    while not result_queue.empty():
        print(result_queue.get())

from multiprocessing import Process, Pipe

def sender(conn):
    for i in range(5):
        conn.send(i)
        print(f"send: {i}")
    conn.send(None)          # sentinel to signal the end
    conn.close()

def receiver(conn):
    while True:
        item = conn.recv()
        if item is None:
            break
        print(f"Received: {item}")
    conn.close()

if __name__ == "__main__":
    sender_conn, receiver_conn = Pipe()

    sender_process = Process(target=sender, args=(sender_conn,))
    receiver_process = Process(target=receiver, args=(receiver_conn,))

    sender_process.start()
    receiver_process.start()

    sender_process.join()
    receiver_process.join()

from multiprocessing import Process, Pipe

def sender(conn):
    for i in range(5):
        conn.send(i)
        print(f"send: {i}")
    conn.send(None)          # sentinel to signal the end
    conn.close()

def receiver(conn):
    while True:
        item = conn.recv()
        if item is None:
            break
        print(f"Received: {item}")
    conn.close()

if __name__ == "__main__":
    sender_conn, receiver_conn = Pipe()

    sender_process = Process(target=sender, args=(sender_conn,))
    receiver_process = Process(target=receiver, args=(receiver_conn,))

    sender_process.start()
    receiver_process.start()

    sender_process.join()
    receiver_process.join()

from multiprocessing import Process, Array, Value

def square_numbers(numbers, result, first_square):
    for i in range(len(numbers)):
        result[i] = numbers[i] ** 2
    first_square.value = numbers[0] ** 2      # set the shared Value

if __name__ == "__main__":
    shared_array = Array('i', range(5))       # 'i' = array of integers
    shared_value = Value('i', 0)              # 'i' = a single integer
    numbers = [1, 2, 3, 4, 5]

    process = Process(target=square_numbers, args=(numbers, shared_array, shared_value))
    process.start()
    process.join()

    print("Shared Array:", list(shared_array))   # [1, 4, 9, 16, 25]
    print("Shared Value:", shared_value.value)   # 1

from multiprocessing import Process, Array, Value

def square_numbers(numbers, result, first_square):
    for i in range(len(numbers)):
        result[i] = numbers[i] ** 2
    first_square.value = numbers[0] ** 2      # set the shared Value

if __name__ == "__main__":
    shared_array = Array('i', range(5))       # 'i' = array of integers
    shared_value = Value('i', 0)              # 'i' = a single integer
    numbers = [1, 2, 3, 4, 5]

    process = Process(target=square_numbers, args=(numbers, shared_array, shared_value))
    process.start()
    process.join()

    print("Shared Array:", list(shared_array))   # [1, 4, 9, 16, 25]
    print("Shared Value:", shared_value.value)   # 1