Searched refs:thread_pool (Results 1 – 3 of 3) sorted by relevance
| /rocksdb-6.9/trace_replay/ |
| D | trace_replay.cc | 303 ThreadPoolImpl thread_pool; in MultiThreadReplay() local
304 thread_pool.SetHostEnv(env_); in MultiThreadReplay()
307 thread_pool.SetBackgroundThreads(static_cast<int>(threads_num)); in MultiThreadReplay()
309 thread_pool.SetBackgroundThreads(1); in MultiThreadReplay()
331 thread_pool.Schedule(&Replayer::BGWorkWriteBatch, ra.release(), nullptr, in MultiThreadReplay()
335 thread_pool.Schedule(&Replayer::BGWorkGet, ra.release(), nullptr, in MultiThreadReplay()
339 thread_pool.Schedule(&Replayer::BGWorkIterSeek, ra.release(), nullptr, in MultiThreadReplay()
343 thread_pool.Schedule(&Replayer::BGWorkIterSeekForPrev, ra.release(), in MultiThreadReplay()
363 thread_pool.JoinAllThreads(); in MultiThreadReplay()
|
| /rocksdb-6.9/util/ |
| D | threadpool_imp.cc | 274 BGThreadMetadata(ThreadPoolImpl::Impl* thread_pool, size_t thread_id) in BGThreadMetadata()
275 : thread_pool_(thread_pool), thread_id_(thread_id) {} in BGThreadMetadata()
503 ThreadPoolImpl* thread_pool = new ThreadPoolImpl(); in NewThreadPool() local
504 thread_pool->SetBackgroundThreads(num_threads); in NewThreadPool()
505 return thread_pool; in NewThreadPool()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 578 std::vector<port::Thread> thread_pool; in Run() local
579 thread_pool.reserve(num_threads - 1); in Run()
581 thread_pool.emplace_back(&CompactionJob::ProcessKeyValueCompaction, this, in Run()
590 for (auto& thread : thread_pool) { in Run()
626 thread_pool.clear(); in Run()
675 thread_pool.emplace_back(verify_table, in Run()
679 for (auto& thread : thread_pool) { in Run()
|