Inter process communication using numpy.nmap

inter_process_communication_using_nmap.py

import numpy as np
from multiprocessing import Process

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

filename = "/tmp/array_file.arr"
file = np.memmap(filename, mode="w+", dtype='float32', shape=(6,))     
proc = Process(target=worker, args=(file,))
proc.start()

while True:
    read_value = np.memmap(filename, dtype='float32', mode='r', shape=(6,))
    print("Value read is ", read_value)

proc.join()