Fix tests

This commit is contained in:
gabime 2024-12-08 23:03:12 +02:00
parent 924ffc4fbd
commit 6cbddcba39

View File

@ -113,11 +113,12 @@ TEST_CASE("multi threads", "[async]") {
size_t n_threads = 10;
{
auto [logger, async_sink] = creat_async_logger(queue_size, test_sink);
std::vector<std::thread> threads;
for (size_t i = 0; i < n_threads; i++) {
threads.emplace_back([&] {
for (size_t j = 0; j < messages; j++) {
logger->info("Hello message #{}", j);
threads.emplace_back([l=logger, msgs = messages] {
for (size_t j = 0; j < msgs; j++) {
l->info("Hello message #{}", j);
}
});
logger->flush();