44 struct ThreadPoolImpl::Impl {  struct in ROCKSDB_NAMESPACE::ThreadPoolImpl
54   unsigned int GetQueueLen() const {  in GetQueueLen()
62   void WakeUpAllThreads() {  in WakeUpAllThreads()
75   void SetHostEnv(Env* env) { env_ = env; }  in SetHostEnv()
77   Env* GetHostEnv() const { return env_; }  in GetHostEnv()
79   bool HasExcessiveThread() const {  in HasExcessiveThread()
86   bool IsLastExcessiveThread(size_t thread_id) const {  in IsLastExcessiveThread()
90   bool IsExcessiveThread(size_t thread_id) const {  in IsExcessiveThread()
96   Env::Priority GetThreadPriority() const { return priority_; }  in GetThreadPriority()
99   void SetThreadPriority(Env::Priority priority) { priority_ = priority; }  in SetThreadPriority()
104  bool low_io_priority_;
105  bool low_cpu_priority_;
106  Env::Priority priority_;
107  Env* env_;
109  int total_threads_limit_;
110  std::atomic_uint queue_len_;  // Queue length. Used for stats reporting
111  bool exit_all_threads_;
112  bool wait_for_jobs_to_complete_;
115  struct BGItem {
121   using BGQueue = std::deque<BGItem>;
122   BGQueue       queue_;
124   std::mutex               mu_;
125   std::condition_variable  bgsignal_;
126   std::vector<port::Thread> bgthreads_;
131 ThreadPoolImpl::Impl::Impl()  in Impl()  function in ROCKSDB_NAMESPACE::ThreadPoolImpl::Impl