This commit is contained in:
mutouyun 2018-11-27 20:45:28 +08:00
parent f0cbfbff7c
commit 2f175b9da9

View File

@ -69,7 +69,9 @@ void test_prod_cons(void) {
for (auto& t : consumers) {
t = std::thread{[&, cid] {
auto cur = cq__->cursor();
std::cout << "start consumer " << &t << ": cur = " << (int)cur << std::endl;
if (Confirmation) {
std::cout << "start consumer " << &t << ": cur = " << (int)cur << std::endl;
}
cq__->connect();
std::unique_ptr<cq_t, void(*)(cq_t*)> guard(cq__, [](cq_t* cq) { cq->disconnect(); });