This commit is contained in:
gabime 2018-06-01 17:52:05 +03:00
parent 5997e5aae7
commit 4b9949de7b
6 changed files with 4 additions and 11 deletions

View File

@ -75,15 +75,11 @@ int main(int argc, char *argv[])
for (int i = 0; i < 3; ++i) for (int i = 0; i < 3; ++i)
{ {
spdlog::init_thread_pool(queue_size, 1); spdlog::init_thread_pool(queue_size, 1);
auto as = spdlog::basic_logger_mt<spdlog::create_async>("as", "logs/basic_async.log", true); auto as = spdlog::basic_logger_mt<spdlog::create_async>("as", "logs/basic_async.log", true);
bench_mt(howmany, as, threads); bench_mt(howmany, as, threads);
spdlog::drop("as"); spdlog::drop("as");
} }
} }
catch (std::exception &ex) catch (std::exception &ex)
{ {

View File

@ -72,7 +72,6 @@ public:
return true; return true;
} }
private: private:
size_t max_items_; size_t max_items_;
std::mutex queue_mutex_; std::mutex queue_mutex_;

View File

@ -139,7 +139,6 @@ public:
return msg_counter_.load(std::memory_order_relaxed); return msg_counter_.load(std::memory_order_relaxed);
} }
private: private:
std::atomic<size_t> msg_counter_; // total # of messages processed in this pool std::atomic<size_t> msg_counter_; // total # of messages processed in this pool
q_type q_; q_type q_;

View File

@ -77,7 +77,6 @@ TEST_CASE("tp->wait_empty() ", "[async]")
logger->flush(); logger->flush();
tp.reset(); tp.reset();
REQUIRE(test_sink->msg_counter() == messages); REQUIRE(test_sink->msg_counter() == messages);
REQUIRE(test_sink->flush_counter() == 1); REQUIRE(test_sink->flush_counter() == 1);
} }