test_parallel.py 文件源码

def test_preduce_one_process(self):
        """ Test that preduce reduces to functools.reduce for a single process """
        integers = list(range(0, 10))
        preduce_results = preduce(add, integers, processes = 1)
        reduce_results = reduce(add, integers)

        self.assertEqual(preduce_results, reduce_results)