folly::observer_detail::ObserverManager::NextQueue Class Reference

Public Member Functions
	NextQueue (ObserverManager &manager)
void	add (Core::WeakPtr core)
	~NextQueue ()

Private Attributes
ObserverManager &	manager_
MPMCQueue< Core::WeakPtr >	queue_
std::thread	thread_
std::atomic< bool >	stop_ {false}

Detailed Description

Definition at line 104 of file ObserverManager.cpp.

Constructor & Destructor Documentation

folly::observer_detail::ObserverManager::NextQueue::NextQueue ( ObserverManager &  manager )

inlineexplicit

Definition at line 106 of file ObserverManager.cpp.

References folly::gen::move, and folly::observer_detail::ObserverManager::CurrentQueue::queue_.

      : manager_(manager), queue_(kNextQueueSize) {
    thread_ = std::thread([&]() {
      Core::WeakPtr queueCoreWeak;

      while (true) {
        queue_.blockingRead(queueCoreWeak);
        if (stop_) {
          return;
        }

        std::vector<Core::Ptr> cores;
        {
          auto queueCore = queueCoreWeak.lock();
          if (!queueCore) {
            continue;
          }
          cores.emplace_back(std::move(queueCore));
        }

        {
          SharedMutexReadPriority::WriteHolder wh(manager_.versionMutex_);

          // We can't pick more tasks from the queue after we bumped the
          // version, so we have to do this while holding the lock.
          while (cores.size() < kNextQueueSize && queue_.read(queueCoreWeak)) {
            if (stop_) {
              return;
            }
            if (auto queueCore = queueCoreWeak.lock()) {
              cores.emplace_back(std::move(queueCore));
            }
          }

          ++manager_.version_;
        }

        for (auto& core : cores) {
          manager_.scheduleRefresh(std::move(core), manager_.version_, true);
        }
      }
    });
  }

folly::observer_detail::ObserverManager::NextQueue::~NextQueue ( )

inline

Definition at line 154 of file ObserverManager.cpp.

References folly::observer_detail::ObserverManager::CurrentQueue::queue_.

               {
    stop_ = true;
    // Write to the queue to notify the thread.
    queue_.blockingWrite(Core::WeakPtr());
    thread_.join();
  }

Member Function Documentation

void folly::observer_detail::ObserverManager::NextQueue::add ( Core::WeakPtr  core )

inline

Definition at line 150 of file ObserverManager.cpp.

References folly::gen::move, and folly::observer_detail::ObserverManager::CurrentQueue::queue_.

                             {
    queue_.blockingWrite(std::move(core));
  }

Member Data Documentation

ObserverManager& folly::observer_detail::ObserverManager::NextQueue::manager_

private

Definition at line 162 of file ObserverManager.cpp.

MPMCQueue<Core::WeakPtr> folly::observer_detail::ObserverManager::NextQueue::queue_

private

Definition at line 163 of file ObserverManager.cpp.

std::atomic<bool> folly::observer_detail::ObserverManager::NextQueue::stop_ {false}

private

Definition at line 165 of file ObserverManager.cpp.

std::thread folly::observer_detail::ObserverManager::NextQueue::thread_

private

Definition at line 164 of file ObserverManager.cpp.

---

The documentation for this class was generated from the following file:

• proxygen/folly/folly/experimental/observer/detail/ObserverManager.cpp