test_parallel.py 文件源码

def test_on_numpy_arrays(self):
        """ Test sum of numpy arrays as parallel reduce"""
        arrays = [np.zeros((32,32)) for _ in range(10)]
        s = preduce(add, arrays, processes = 2)

        self.assertTrue(np.allclose(s, arrays[0]))