Searched refs:consumerThread_ (Results 1 – 12 of 12) sorted by relevance
145 if (consumerThread_ != nullptr) { in ~StreamConsumer()146 consumerThread_->join(); in ~StreamConsumer()147 delete consumerThread_; in ~StreamConsumer() local156 std::thread* consumerThread_ = nullptr; variable
144 if (consumerThread_ != nullptr) { in ~StreamConsumer()145 consumerThread_->join(); in ~StreamConsumer()146 delete consumerThread_; in ~StreamConsumer() local155 std::thread* consumerThread_ = nullptr; variable
169 if (consumerThread_ != nullptr) { in ~StreamConsumer()170 consumerThread_->join(); in ~StreamConsumer()171 delete consumerThread_; in ~StreamConsumer() local180 std::thread* consumerThread_ = nullptr; variable
223 if (consumerThread_ != nullptr) { in ~StreamConsumer()224 consumerThread_->join(); in ~StreamConsumer()225 delete consumerThread_; in ~StreamConsumer() local234 std::thread* consumerThread_ = nullptr; variable
314 consumerThread_ = new std::thread([this, listener] { in CreateProducer()
313 consumerThread_ = new std::thread([this, listener] { in CreateProducer()
352 consumerThread_ = new std::thread([this, listener] { in CreateProducer()
400 consumerThread_ = new std::thread([this, listener] { in CreateProducer()
527 consumerThread_ = new std::thread([this, listener] { in CreateProducer()