From de6bc3b5d2dc8894f16ffdabfc51f78208348e7d Mon Sep 17 00:00:00 2001 From: co63oc Date: Fri, 23 Feb 2024 08:36:49 +0800 Subject: [PATCH] Update multi_threading_test.cc --- paddle/cinn/utils/multi_threading_test.cc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/paddle/cinn/utils/multi_threading_test.cc b/paddle/cinn/utils/multi_threading_test.cc index abd429a4b1677a..bd081fea2b56c6 100644 --- a/paddle/cinn/utils/multi_threading_test.cc +++ b/paddle/cinn/utils/multi_threading_test.cc @@ -34,19 +34,19 @@ TEST(JobDispatcher, SequenceDispatcher) { TEST(parallel_run, Basic) { std::vector results(100, -1); - auto woker_fn = [&results](int index) { + auto worker_fn = [&results](int index) { CHECK_LT(index, results.size()) << "index invalid"; results[index] = index; }; // check process every index in the extent of [0, 100) with step 1 - parallel_run(woker_fn, SequenceDispatcher(0, 100), 2); + parallel_run(worker_fn, SequenceDispatcher(0, 100), 2); for (int i = 0; i < 100; ++i) { ASSERT_EQ(results[i], i); } // check only indexes in the extent of [0, 100) with step 3 are processed results.assign(100, -1); - parallel_run(woker_fn, SequenceDispatcher(0, 100, 3), 3); + parallel_run(worker_fn, SequenceDispatcher(0, 100, 3), 3); for (int i = 0; i < 100; ++i) { if (i % 3 == 0) { ASSERT_EQ(results[i], i);