test_async.py 文件源码

def test_run_async(self):
        counter = mp.Value('l', 0)

        def run_func(process_idx):
            for _ in range(1000):
                with counter.get_lock():
                    counter.value += 1
        async.run_async(4, run_func)
        self.assertEqual(counter.value, 4000)