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