activeThreads_ | folly::ThreadPoolExecutor | protected |
add(Func func) override | folly::IOThreadPoolExecutor | virtual |
add(Func func, std::chrono::milliseconds expiration, Func expireCallback=nullptr) override | folly::IOThreadPoolExecutor | virtual |
addObserver(std::shared_ptr< Observer >) | folly::ThreadPoolExecutor | |
addThreads(size_t n) | folly::ThreadPoolExecutor | protected |
addWithPriority(Func, int8_t priority) | folly::Executor | virtual |
DefaultKeepAliveExecutor() | folly::DefaultKeepAliveExecutor | inline |
ensureActiveThreads() | folly::ThreadPoolExecutor | protected |
ensureJoined() | folly::ThreadPoolExecutor | protected |
eventBaseManager_ | folly::IOThreadPoolExecutor | private |
getEventBase() override | folly::IOThreadPoolExecutor | virtual |
getEventBase(ThreadPoolExecutor::ThreadHandle *) | folly::IOThreadPoolExecutor | static |
getEventBaseManager() | folly::IOThreadPoolExecutor | |
getKeepAliveToken(ExecutorT *executor) | folly::Executor | inlinestatic |
getKeepAliveToken(ExecutorT &executor) | folly::Executor | inlinestatic |
getName() | folly::ThreadPoolExecutor | |
getNumPriorities() const | folly::Executor | inlinevirtual |
getPendingTaskCount() | folly::ThreadPoolExecutor | |
getPendingTaskCountImpl() override | folly::IOThreadPoolExecutor | privatevirtual |
getPoolStats() | folly::ThreadPoolExecutor | |
getThreadFactory() | folly::ThreadPoolExecutor | inline |
HI_PRI | folly::Executor | static |
IOThreadPoolExecutor(size_t numThreads, std::shared_ptr< ThreadFactory > threadFactory=std::make_shared< NamedThreadFactory >("IOThreadPool"), folly::EventBaseManager *ebm=folly::EventBaseManager::get(), bool waitForAll=false) | folly::IOThreadPoolExecutor | explicit |
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 |
keepAliveAcquire() | folly::Executor | protectedvirtual |
keepAliveJoined_ | folly::ThreadPoolExecutor | protected |
keepAliveRelease() | folly::Executor | protectedvirtual |
LO_PRI | folly::Executor | static |
makeKeepAlive(ExecutorT *executor) | folly::Executor | inlineprotectedstatic |
makeThread() override | folly::IOThreadPoolExecutor | privatevirtual |
maxThreads_ | folly::ThreadPoolExecutor | protected |
MID_PRI | folly::Executor | static |
minActive() | folly::ThreadPoolExecutor | protected |
minThreads_ | folly::ThreadPoolExecutor | protected |
nextThread_ | folly::IOThreadPoolExecutor | private |
numActiveThreads() | folly::ThreadPoolExecutor | |
numThreads() | folly::ThreadPoolExecutor | |
observers_ | folly::ThreadPoolExecutor | protected |
pickThread() | folly::IOThreadPoolExecutor | private |
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::IOThreadPoolExecutor | privatevirtual |
subscribeToTaskStats(TaskStatsCallback cb) | folly::ThreadPoolExecutor | |
TaskStatsCallback typedef | folly::ThreadPoolExecutor | |
taskStatsCallbacks_ | folly::ThreadPoolExecutor | protected |
thisThread_ | folly::IOThreadPoolExecutor | private |
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::IOThreadPoolExecutor | privatevirtual |
threadsToJoin_ | folly::ThreadPoolExecutor | protected |
threadTimeout_ | folly::ThreadPoolExecutor | protected |
tryTimeoutThread() | folly::ThreadPoolExecutor | protected |
weakRef() | folly::DefaultKeepAliveExecutor | inline |
withAll(FunctionRef< void(ThreadPoolExecutor &)> f) | folly::ThreadPoolExecutor | static |
~DefaultKeepAliveExecutor() | folly::DefaultKeepAliveExecutor | inlinevirtual |
~Executor() | folly::Executor | inlinevirtual |
~IOExecutor() override=default | folly::IOExecutor | |
~IOThreadPoolExecutor() override | folly::IOThreadPoolExecutor | |
~ThreadPoolExecutor() override | folly::ThreadPoolExecutor | |