diff --git a/src/coro_io/tests/test_rate_limiter.cpp b/src/coro_io/tests/test_rate_limiter.cpp index dac63d5f4..55d79cbad 100644 --- a/src/coro_io/tests/test_rate_limiter.cpp +++ b/src/coro_io/tests/test_rate_limiter.cpp @@ -64,16 +64,17 @@ TEST_CASE("test SmoothBurstyRateLimiter multi coroutine") { double cost_diff = 0.1; coro_io::SmoothBurstyRateLimiter rateLimiter(permits_per_second); - auto consumer = [&]() -> async_simple::coro::Lazy { + auto consumer = [&](int coroutine_num) -> async_simple::coro::Lazy { for (int i = 0; i < permits_to_acquire_every_coroutine; i++) { co_await rateLimiter.acquire(1); + ELOG_INFO << "coroutine " << coroutine_num << " acquired"; } }; auto consumerListLazy = [&]() -> async_simple::coro::Lazy { std::vector> lazyList; for (int i = 0; i < num_of_coroutine; i++) { - lazyList.push_back(consumer()); + lazyList.push_back(consumer(i)); } co_await collectAllPara(std::move(lazyList)); };