Inter process communication using multiprocessing.shared_memory

inter_process_communication_using_shared_memory.py

import numpy as np
from multiprocessing import shared_memory, Process

def worker(shared_variable):
    existing_shm = shared_memory.SharedMemory(name=shared_variable.name)
    myarray = np.ndarray((6,), dtype=np.int64, buffer=existing_shm.buf)
    count = 0
    while True:
        count += 1
        myarray[-1] =  count

shm = shared_memory.SharedMemory(create=True, size=np.zeros(6).nbytes)      
proc = Process(target=worker, args=(shm,))
proc.start()

while True:
    read_value = np.ndarray((6,), dtype=np.int64, buffer=shm.buf)
    print("Value read is ", read_value)

proc.join()