Searched refs:threads_ (Results 1 – 4 of 4) sorted by relevance
223 threads_.emplace_back([&]() { WriteThread(); }); in Run()224 threads_.emplace_back([&]() { PrefixMutatorThread(); }); in Run()225 threads_.emplace_back([&]() { IteratorHoldThread(); }); in Run()237 for (auto& t : threads_) { in Run()240 threads_.clear(); in Run()291 std::vector<port::Thread> threads_; member in ROCKSDB_NAMESPACE::WriteStress
543 threads_.push_back(std::move(th)); in ThreadedWriter()549 for (size_t i = 0; i < threads_.size(); ++i) { in Stop()554 for (auto& th : threads_) { in Stop()558 threads_.clear(); in Stop()
278 virtual ~ThreadedWriter() { assert(threads_.empty()); } in ~ThreadedWriter()291 std::vector<port::Thread> threads_; variable
470 std::vector<port::Thread> threads_; member in ROCKSDB_NAMESPACE::BackupEngineImpl563 for (auto& t : threads_) { in ~BackupEngineImpl()743 threads_.reserve(options_.max_background_operations); in Initialize()745 threads_.emplace_back([this]() { in Initialize()