Haciendo que mi matriz NumPy sea compartida entre procesos

He leído algunas de las preguntas sobre SO sobre compartir arrays y parece lo suficientemente simple como para matrices simples, pero estoy atascado tratando de que funcione para la matriz que tengo.

import numpy as np
data=np.zeros(250,dtype='float32, (250000,2)float32')

He intentado convertir esto en una matriz compartida tratando de hacer de alguna maneramp.Array acepta eldata, También he intentado crear la matriz utilizando ctypes como tales:

import multiprocessing as mp
data=mp.Array('c_float, (250000)c_float',250)

La única manera de lograr que mi código funcione no es pasar los datos a la función, sino pasar una cadena codificada para que se descomprima / decodifique, esto sin embargo terminaría en n (número de cadenas) que se llaman procesos que parecen redundantes. Mi implementación deseada se basa en dividir la lista de cadenas binarias en x (número de procesos) y pasar este fragmento,data y unindex a los procesos que funciona excepto quedata Se modifica localmente, de ahí la pregunta sobrecomo hacerlo compartido, cualquier ejemplo que trabaje con una matriz numpy personalizada (anidada) ya sería de gran ayuda.

PD: Esta pregunta es un seguimiento deMultiprocesamiento Python

Respuestas a la pregunta(2)

Su respuesta a la pregunta