cache_mc_shared.py 文件源码

def _create_xs_shared(xs):
    """Create shared variable for data (xs).
    """
    n = len(xs.reshape(-1))
    xs_shared_base = multiprocessing.Array(ctypes.c_double, n)
    shape = xs.shape

    view = np.ctypeslib.as_array(xs_shared_base.get_obj())
    view = view.reshape(shape)
    view[:] = xs[:]
    del view

    xs_shared = (xs_shared_base, shape)

    return xs_shared