utility::executor::Executor< ExecutorHandler > Class Template Reference

#include <executor.h>

Public Member Functions
	Executor ()
	~Executor ()
void	AddExecute (ExecutorHandler executor_handler)

Private Attributes
std::queue< ExecutorHandler >	queue_
std::mutex	mutex_lock_
std::mutex	exit_mutex_lock_
std::thread	thread_
std::condition_variable	cond_var_
std::atomic< bool >	exit_request_
std::atomic< bool >	running_

Detailed Description

template<typename ExecutorHandler>
class utility::executor::Executor< ExecutorHandler >

Definition at line 22 of file executor.h.

Constructor & Destructor Documentation

Executor()

template<typename ExecutorHandler >

utility::executor::Executor< ExecutorHandler >::Executor ( )

inline

Definition at line 25 of file executor.h.

             : exit_request_{false}, running_{false} {
    thread_ = std::thread([&]() {
      std::unique_lock<std::mutex> exit_lck(exit_mutex_lock_);
      while (!exit_request_.load()) {
        if (!running_.load()) { cond_var_.wait(exit_lck); }
        if (running_) {
          std::unique_lock<std::mutex> lck(mutex_lock_);
          while (!queue_.empty()) {
            auto func = queue_.front();
            lck.unlock();
            func();
            lck.lock();
            queue_.pop();
          }
          running_.store(false);
        }
      }
    });
  }

References utility::executor::Executor< ExecutorHandler >::cond_var_, utility::executor::Executor< ExecutorHandler >::exit_mutex_lock_, utility::executor::Executor< ExecutorHandler >::exit_request_, utility::executor::Executor< ExecutorHandler >::mutex_lock_, utility::executor::Executor< ExecutorHandler >::queue_, utility::executor::Executor< ExecutorHandler >::running_, and utility::executor::Executor< ExecutorHandler >::thread_.

~Executor()

template<typename ExecutorHandler >

utility::executor::Executor< ExecutorHandler >::~Executor ( )

inline

Definition at line 46 of file executor.h.

              {
    exit_request_ = true;
    running_ = false;
    cond_var_.notify_one();
    thread_.join();
  }

References utility::executor::Executor< ExecutorHandler >::cond_var_, utility::executor::Executor< ExecutorHandler >::exit_request_, utility::executor::Executor< ExecutorHandler >::running_, and utility::executor::Executor< ExecutorHandler >::thread_.

Member Function Documentation

AddExecute()

template<typename ExecutorHandler >

void utility::executor::Executor< ExecutorHandler >::AddExecute ( ExecutorHandler  executor_handler )

inline

Definition at line 54 of file executor.h.

                                                    {
    std::unique_lock<std::mutex> lck(mutex_lock_);
    queue_.push(std::move(executor_handler));
    running_.store(true);
    cond_var_.notify_one();
  }

References utility::executor::Executor< ExecutorHandler >::cond_var_, utility::executor::Executor< ExecutorHandler >::mutex_lock_, utility::executor::Executor< ExecutorHandler >::queue_, and utility::executor::Executor< ExecutorHandler >::running_.

Member Data Documentation

cond_var_

template<typename ExecutorHandler >

std::condition_variable utility::executor::Executor< ExecutorHandler >::cond_var_

private

Definition at line 71 of file executor.h.

Referenced by utility::executor::Executor< ExecutorHandler >::AddExecute(), utility::executor::Executor< ExecutorHandler >::Executor(), and utility::executor::Executor< ExecutorHandler >::~Executor().

exit_mutex_lock_

template<typename ExecutorHandler >

std::mutex utility::executor::Executor< ExecutorHandler >::exit_mutex_lock_

private

Definition at line 67 of file executor.h.

Referenced by utility::executor::Executor< ExecutorHandler >::Executor().

exit_request_

template<typename ExecutorHandler >

std::atomic<bool> utility::executor::Executor< ExecutorHandler >::exit_request_

private

Definition at line 73 of file executor.h.

Referenced by utility::executor::Executor< ExecutorHandler >::Executor(), and utility::executor::Executor< ExecutorHandler >::~Executor().

mutex_lock_

template<typename ExecutorHandler >

std::mutex utility::executor::Executor< ExecutorHandler >::mutex_lock_

private

Definition at line 65 of file executor.h.

Referenced by utility::executor::Executor< ExecutorHandler >::AddExecute(), and utility::executor::Executor< ExecutorHandler >::Executor().

queue_

template<typename ExecutorHandler >

std::queue<ExecutorHandler> utility::executor::Executor< ExecutorHandler >::queue_

private

Definition at line 63 of file executor.h.

Referenced by utility::executor::Executor< ExecutorHandler >::AddExecute(), and utility::executor::Executor< ExecutorHandler >::Executor().

running_

template<typename ExecutorHandler >

std::atomic<bool> utility::executor::Executor< ExecutorHandler >::running_

private

Definition at line 75 of file executor.h.

Referenced by utility::executor::Executor< ExecutorHandler >::AddExecute(), utility::executor::Executor< ExecutorHandler >::Executor(), and utility::executor::Executor< ExecutorHandler >::~Executor().

thread_

template<typename ExecutorHandler >

std::thread utility::executor::Executor< ExecutorHandler >::thread_

private

Definition at line 69 of file executor.h.

Referenced by utility::executor::Executor< ExecutorHandler >::Executor(), and utility::executor::Executor< ExecutorHandler >::~Executor().

---

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

• /home/runner/work/diag-client-lib/diag-client-lib/diag-client-lib/lib/utility-support/utility/executor.h