Searched refs:ThreadPoolImpl (Results 1 – 5 of 5) sorted by relevance
44 struct ThreadPoolImpl::Impl {131 ThreadPoolImpl::Impl::Impl() in Impl()272 ThreadPoolImpl::Impl* thread_pool_;423 ThreadPoolImpl::ThreadPoolImpl() : in ThreadPoolImpl() function in ROCKSDB_NAMESPACE::ThreadPoolImpl428 ThreadPoolImpl::~ThreadPoolImpl() { in ~ThreadPoolImpl()431 void ThreadPoolImpl::JoinAllThreads() { in JoinAllThreads()439 int ThreadPoolImpl::GetBackgroundThreads() { in GetBackgroundThreads()451 void ThreadPoolImpl::LowerIOPriority() { in LowerIOPriority()455 void ThreadPoolImpl::LowerCPUPriority() { in LowerCPUPriority()483 int ThreadPoolImpl::UnSchedule(void* arg) { in UnSchedule()[all …]
19 class ThreadPoolImpl : public ThreadPool {21 ThreadPoolImpl();22 ~ThreadPoolImpl();24 ThreadPoolImpl(ThreadPoolImpl&&) = delete;25 ThreadPoolImpl& operator=(ThreadPoolImpl&&) = delete;
392 std::vector<ThreadPoolImpl> thread_pools_storage_;397 std::vector<ThreadPoolImpl>& thread_pools_;413 ThreadPoolImpl::PthreadCall("mutex_init", pthread_mutex_init(&mu_, nullptr)); in PosixEnv()464 ThreadPoolImpl::PthreadCall( in StartThread()466 ThreadPoolImpl::PthreadCall("lock", pthread_mutex_lock(&mu_)); in StartThread()468 ThreadPoolImpl::PthreadCall("unlock", pthread_mutex_unlock(&mu_)); in StartThread()
76 std::vector<ThreadPoolImpl> thread_pools_;
303 ThreadPoolImpl thread_pool; in MultiThreadReplay()