activeThreads_ | folly::ThreadPoolExecutor | protected |
add(Func func) override | folly::CPUThreadPoolExecutor | virtual |
add(Func func, std::chrono::milliseconds expiration, Func expireCallback=nullptr) override | folly::CPUThreadPoolExecutor | virtual |
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::ThreadPoolExecutor | protected |
addWithPriority(Func func, int8_t priority) override | folly::CPUThreadPoolExecutor | virtual |
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::CPUThreadPoolExecutor | explicit |
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::DefaultKeepAliveExecutor | inline |
ensureActiveThreads() | folly::ThreadPoolExecutor | protected |
ensureJoined() | folly::ThreadPoolExecutor | protected |
getKeepAliveToken(ExecutorT *executor) | folly::Executor | inlinestatic |
getKeepAliveToken(ExecutorT &executor) | folly::Executor | inlinestatic |
getName() | folly::ThreadPoolExecutor | |
getNumPriorities() const override | folly::CPUThreadPoolExecutor | virtual |
getPendingTaskCount() | folly::ThreadPoolExecutor | |
getPendingTaskCountImpl() override | folly::CPUThreadPoolExecutor | privatevirtual |
getPoolStats() | folly::ThreadPoolExecutor | |
getTaskQueue() | folly::CPUThreadPoolExecutor | protected |
getTaskQueueSize() const | folly::CPUThreadPoolExecutor | |
getThreadFactory() | folly::ThreadPoolExecutor | inline |
HI_PRI | folly::Executor | static |
isJoin_ | folly::ThreadPoolExecutor | protected |
isKeepAliveDummy(const KeepAlive< ExecutorT > &keepAlive) | folly::Executor | inlineprotectedstatic |
isWaitForAll_ | folly::ThreadPoolExecutor | protected |
join() | folly::ThreadPoolExecutor | |
joinKeepAlive() | folly::DefaultKeepAliveExecutor | inlineprotected |
joinKeepAliveOnce() | folly::ThreadPoolExecutor | inlineprotected |
joinStoppedThreads(size_t n) | folly::ThreadPoolExecutor | protected |
kDefaultMaxQueueSize | folly::CPUThreadPoolExecutor | static |
keepAliveJoined_ | folly::ThreadPoolExecutor | protected |
LO_PRI | folly::Executor | static |
makeKeepAlive(ExecutorT *executor) | folly::Executor | inlineprotectedstatic |
makeThread() | folly::ThreadPoolExecutor | inlineprotectedvirtual |
maxThreads_ | folly::ThreadPoolExecutor | protected |
MID_PRI | folly::Executor | static |
minActive() | folly::ThreadPoolExecutor | protected |
minThreads_ | folly::ThreadPoolExecutor | protected |
numActiveThreads() | folly::ThreadPoolExecutor | |
numThreads() | folly::ThreadPoolExecutor | |
observers_ | folly::ThreadPoolExecutor | protected |
removeObserver(std::shared_ptr< Observer >) | folly::ThreadPoolExecutor | |
removeThreads(size_t n, bool isJoin) | folly::ThreadPoolExecutor | protected |
runTask(const ThreadPtr &thread, Task &&task) | folly::ThreadPoolExecutor | protectedstatic |
setNumThreads(size_t numThreads) | folly::ThreadPoolExecutor | |
setThreadDeathTimeout(std::chrono::milliseconds timeout) | folly::ThreadPoolExecutor | inline |
setThreadFactory(std::shared_ptr< ThreadFactory > threadFactory) | folly::ThreadPoolExecutor | inline |
stop() | folly::ThreadPoolExecutor | |
stoppedThreads_ | folly::ThreadPoolExecutor | protected |
stopThreads(size_t n) override | folly::CPUThreadPoolExecutor | privatevirtual |
subscribeToTaskStats(TaskStatsCallback cb) | folly::ThreadPoolExecutor | |
taskQueue_ | folly::CPUThreadPoolExecutor | private |
taskShouldStop(folly::Optional< CPUTask > &) | folly::CPUThreadPoolExecutor | private |
TaskStatsCallback typedef | folly::ThreadPoolExecutor | |
taskStatsCallbacks_ | folly::ThreadPoolExecutor | protected |
threadFactory_ | folly::ThreadPoolExecutor | protected |
threadList_ | folly::ThreadPoolExecutor | protected |
threadListLock_ | folly::ThreadPoolExecutor | protected |
ThreadPoolExecutor(size_t maxThreads, size_t minThreads, std::shared_ptr< ThreadFactory > threadFactory, bool isWaitForAll=false) | folly::ThreadPoolExecutor | explicit |
threadPoolHook_ | folly::ThreadPoolExecutor | protected |
ThreadPtr typedef | folly::ThreadPoolExecutor | protected |
threadRun(ThreadPtr thread) override | folly::CPUThreadPoolExecutor | privatevirtual |
threadsToJoin_ | folly::ThreadPoolExecutor | protected |
threadsToStop_ | folly::CPUThreadPoolExecutor | private |
threadTimeout_ | folly::ThreadPoolExecutor | protected |
tryDecrToStop() | folly::CPUThreadPoolExecutor | private |
tryTimeoutThread() | folly::ThreadPoolExecutor | protected |
weakRef() | folly::DefaultKeepAliveExecutor | inline |
withAll(FunctionRef< void(ThreadPoolExecutor &)> f) | folly::ThreadPoolExecutor | static |
~CPUThreadPoolExecutor() override | folly::CPUThreadPoolExecutor | |
~DefaultKeepAliveExecutor() | folly::DefaultKeepAliveExecutor | inlinevirtual |
~Executor() | folly::Executor | inlinevirtual |
~ThreadPoolExecutor() override | folly::ThreadPoolExecutor | |