24 CHECK(
evb_->runInEventBaseThread([
this] { loopKeepAlive_.reset(); }));
44 while (!callbacks.empty()) {
45 auto& callback = callbacks.front();
46 callbacks.pop_front();
47 callback.runLoopCallback();
61 CHECK(!
evb_->inRunningEventBaseThread());
68 callbacks.push_back(*callback);
std::promise< void > destroyPromise_
void swap(Synchronized &rhs)
~VirtualEventBase() override
constexpr detail::Map< Move > move
void runOnDestruction(EventBase::LoopCallback *callback)
folly::Synchronized< LoopCallbackList > onDestructionCallbacks_
—— Concurrent Priority Queue Implementation ——
KeepAlive< EventBase > evb_
EventBase::LoopCallback::List LoopCallbackList
void cancelLoopCallback()
VirtualEventBase(EventBase &evb)
Executor::KeepAlive< ExecutorT > getKeepAliveToken(ExecutorT *executor)
std::future< void > destroy()
std::future< void > destroyFuture_