Inter process communication using multiprocessing queues.

inter_process_communication_using_queue.py

import numpy as np
from multiprocessing import Queue, Process

def worker(shared_queue):
    count = 0
    temp = np.zeros(6)
    while True:
        count += 1
        temp[-1] = count
        shared_queue.put(temp)

queue = Queue()      
proc = Process(target=worker, args=(queue,))
proc.start()

while True:
    read_value = queue.get()
    print("Value read is ", read_value)

proc.join()