proxygen
folly::CPUThreadPoolExecutor Member List

This is the complete list of members for folly::CPUThreadPoolExecutor, including all inherited members.

activeThreads_folly::ThreadPoolExecutorprotected
add(Func func) overridefolly::CPUThreadPoolExecutorvirtual
add(Func func, std::chrono::milliseconds expiration, Func expireCallback=nullptr) overridefolly::CPUThreadPoolExecutorvirtual
add(Func func, int8_t priority, std::chrono::milliseconds expiration, Func expireCallback=nullptr)folly::CPUThreadPoolExecutor
addObserver(std::shared_ptr< Observer >)folly::ThreadPoolExecutor
addThreads(size_t n)folly::ThreadPoolExecutorprotected
addWithPriority(Func func, int8_t priority) overridefolly::CPUThreadPoolExecutorvirtual
CPUThreadPoolExecutor(size_t numThreads, std::unique_ptr< BlockingQueue< CPUTask >> taskQueue, std::shared_ptr< ThreadFactory > threadFactory=std::make_shared< NamedThreadFactory >("CPUThreadPool"))folly::CPUThreadPoolExecutor
CPUThreadPoolExecutor(std::pair< size_t, size_t > numThreads, std::unique_ptr< BlockingQueue< CPUTask >> taskQueue, std::shared_ptr< ThreadFactory > threadFactory=std::make_shared< NamedThreadFactory >("CPUThreadPool"))folly::CPUThreadPoolExecutor
CPUThreadPoolExecutor(size_t numThreads)folly::CPUThreadPoolExecutorexplicit
CPUThreadPoolExecutor(size_t numThreads, std::shared_ptr< ThreadFactory > threadFactory)folly::CPUThreadPoolExecutor
CPUThreadPoolExecutor(std::pair< size_t, size_t > numThreads, std::shared_ptr< ThreadFactory > threadFactory)folly::CPUThreadPoolExecutor
CPUThreadPoolExecutor(size_t numThreads, int8_t numPriorities, std::shared_ptr< ThreadFactory > threadFactory=std::make_shared< NamedThreadFactory >("CPUThreadPool"))folly::CPUThreadPoolExecutor
CPUThreadPoolExecutor(size_t numThreads, int8_t numPriorities, size_t maxQueueSize, std::shared_ptr< ThreadFactory > threadFactory=std::make_shared< NamedThreadFactory >("CPUThreadPool"))folly::CPUThreadPoolExecutor
DefaultKeepAliveExecutor()folly::DefaultKeepAliveExecutorinline
ensureActiveThreads()folly::ThreadPoolExecutorprotected
ensureJoined()folly::ThreadPoolExecutorprotected
getKeepAliveToken(ExecutorT *executor)folly::Executorinlinestatic
getKeepAliveToken(ExecutorT &executor)folly::Executorinlinestatic
getName()folly::ThreadPoolExecutor
getNumPriorities() const overridefolly::CPUThreadPoolExecutorvirtual
getPendingTaskCount()folly::ThreadPoolExecutor
getPendingTaskCountImpl() overridefolly::CPUThreadPoolExecutorprivatevirtual
getPoolStats()folly::ThreadPoolExecutor
getTaskQueue()folly::CPUThreadPoolExecutorprotected
getTaskQueueSize() const folly::CPUThreadPoolExecutor
getThreadFactory()folly::ThreadPoolExecutorinline
HI_PRIfolly::Executorstatic
isJoin_folly::ThreadPoolExecutorprotected
isKeepAliveDummy(const KeepAlive< ExecutorT > &keepAlive)folly::Executorinlineprotectedstatic
isWaitForAll_folly::ThreadPoolExecutorprotected
join()folly::ThreadPoolExecutor
joinKeepAlive()folly::DefaultKeepAliveExecutorinlineprotected
joinKeepAliveOnce()folly::ThreadPoolExecutorinlineprotected
joinStoppedThreads(size_t n)folly::ThreadPoolExecutorprotected
kDefaultMaxQueueSizefolly::CPUThreadPoolExecutorstatic
keepAliveJoined_folly::ThreadPoolExecutorprotected
LO_PRIfolly::Executorstatic
makeKeepAlive(ExecutorT *executor)folly::Executorinlineprotectedstatic
makeThread()folly::ThreadPoolExecutorinlineprotectedvirtual
maxThreads_folly::ThreadPoolExecutorprotected
MID_PRIfolly::Executorstatic
minActive()folly::ThreadPoolExecutorprotected
minThreads_folly::ThreadPoolExecutorprotected
numActiveThreads()folly::ThreadPoolExecutor
numThreads()folly::ThreadPoolExecutor
observers_folly::ThreadPoolExecutorprotected
removeObserver(std::shared_ptr< Observer >)folly::ThreadPoolExecutor
removeThreads(size_t n, bool isJoin)folly::ThreadPoolExecutorprotected
runTask(const ThreadPtr &thread, Task &&task)folly::ThreadPoolExecutorprotectedstatic
setNumThreads(size_t numThreads)folly::ThreadPoolExecutor
setThreadDeathTimeout(std::chrono::milliseconds timeout)folly::ThreadPoolExecutorinline
setThreadFactory(std::shared_ptr< ThreadFactory > threadFactory)folly::ThreadPoolExecutorinline
stop()folly::ThreadPoolExecutor
stoppedThreads_folly::ThreadPoolExecutorprotected
stopThreads(size_t n) overridefolly::CPUThreadPoolExecutorprivatevirtual
subscribeToTaskStats(TaskStatsCallback cb)folly::ThreadPoolExecutor
taskQueue_folly::CPUThreadPoolExecutorprivate
taskShouldStop(folly::Optional< CPUTask > &)folly::CPUThreadPoolExecutorprivate
TaskStatsCallback typedeffolly::ThreadPoolExecutor
taskStatsCallbacks_folly::ThreadPoolExecutorprotected
threadFactory_folly::ThreadPoolExecutorprotected
threadList_folly::ThreadPoolExecutorprotected
threadListLock_folly::ThreadPoolExecutorprotected
ThreadPoolExecutor(size_t maxThreads, size_t minThreads, std::shared_ptr< ThreadFactory > threadFactory, bool isWaitForAll=false)folly::ThreadPoolExecutorexplicit
threadPoolHook_folly::ThreadPoolExecutorprotected
ThreadPtr typedeffolly::ThreadPoolExecutorprotected
threadRun(ThreadPtr thread) overridefolly::CPUThreadPoolExecutorprivatevirtual
threadsToJoin_folly::ThreadPoolExecutorprotected
threadsToStop_folly::CPUThreadPoolExecutorprivate
threadTimeout_folly::ThreadPoolExecutorprotected
tryDecrToStop()folly::CPUThreadPoolExecutorprivate
tryTimeoutThread()folly::ThreadPoolExecutorprotected
weakRef()folly::DefaultKeepAliveExecutorinline
withAll(FunctionRef< void(ThreadPoolExecutor &)> f)folly::ThreadPoolExecutorstatic
~CPUThreadPoolExecutor() overridefolly::CPUThreadPoolExecutor
~DefaultKeepAliveExecutor()folly::DefaultKeepAliveExecutorinlinevirtual
~Executor()folly::Executorinlinevirtual
~ThreadPoolExecutor() overridefolly::ThreadPoolExecutor