ThreadController_NS::SimpleThreadController< FutureReturnType > Class Template Reference

#include <ThreadController.h>

Inheritance diagram for ThreadController_NS::SimpleThreadController< FutureReturnType >:

Public Member Functions
	SimpleThreadController ()=delete
template<bool future_return_void = std::is_void<FutureReturnType>::value>
	SimpleThreadController (const int max_threads, std::enable_if_t< future_return_void > *=0)
template<bool future_return_void = std::is_void<FutureReturnType>::value>
	SimpleThreadController (const int max_threads, const FutureGetter< FutureReturnType > future_getter, std::enable_if_t<!future_return_void > *=0)
virtual	~SimpleThreadController ()
virtual int	getThreadCount () const
virtual int	getRunningThreadCount () const
virtual void	checkThreadsStatus ()
template<typename FuncType , typename... Args>
void	startThread (FuncType &&func, Args &&...args)
virtual void	finish ()

Protected Member Functions
template<bool future_return_void = std::is_void<FutureReturnType>::value>
void	get_future (std::future< FutureReturnType > &future, std::enable_if_t< future_return_void > *=0)
template<bool future_return_void = std::is_void<FutureReturnType>::value>
void	get_future (std::future< FutureReturnType > &future, std::enable_if_t<!future_return_void > *=0)

Private Attributes
const int	max_threads_
const FutureGetter < FutureReturnType >	future_getter_ {}
std::vector< std::future < FutureReturnType > >	threads_

Detailed Description

template<typename FutureReturnType = void>
class ThreadController_NS::SimpleThreadController< FutureReturnType >

Definition at line 39 of file ThreadController.h.

Constructor & Destructor Documentation

template<typename FutureReturnType = void>

ThreadController_NS::SimpleThreadController< FutureReturnType >::SimpleThreadController ( )

delete

template<typename FutureReturnType = void>

template<bool future_return_void = std::is_void<FutureReturnType>::value>

ThreadController_NS::SimpleThreadController< FutureReturnType >::SimpleThreadController ( const int  max_threads, std::enable_if_t< future_return_void > *  = 0  )

inline

Definition at line 43 of file ThreadController.h.

      : max_threads_(max_threads) {}

template<typename FutureReturnType = void>

template<bool future_return_void = std::is_void<FutureReturnType>::value>

ThreadController_NS::SimpleThreadController< FutureReturnType >::SimpleThreadController ( const int  max_threads, const FutureGetter< FutureReturnType >  future_getter, std::enable_if_t<!future_return_void > *  = 0  )

inline

Definition at line 46 of file ThreadController.h.

      : max_threads_(max_threads), future_getter_(future_getter) {}

template<typename FutureReturnType = void>

virtual ThreadController_NS::SimpleThreadController< FutureReturnType >::~SimpleThreadController ( )

inlinevirtual

Definition at line 50 of file ThreadController.h.

{}

Member Function Documentation

template<typename FutureReturnType = void>

virtual void ThreadController_NS::SimpleThreadController< FutureReturnType >::checkThreadsStatus ( )

inlinevirtual

Reimplemented in ThreadController_NS::SimpleRunningThreadController< FutureReturnType >.

Definition at line 53 of file ThreadController.h.

References ThreadController_NS::SimpleThreadController< FutureReturnType >::get_future(), ThreadController_NS::SimpleThreadController< FutureReturnType >::getRunningThreadCount(), ThreadController_NS::SimpleThreadController< FutureReturnType >::max_threads_, and ThreadController_NS::SimpleThreadController< FutureReturnType >::threads_.

Referenced by ThreadController_NS::SimpleRunningThreadController< FutureReturnType >::checkThreadsStatus(), and anonymous_namespace{TableArchiver.cpp}::update_or_drop_column_ids_in_table_files().

                                    {
    while (getRunningThreadCount() >= max_threads_) {
      std::this_thread::yield();
      threads_.erase(std::remove_if(threads_.begin(),
                                    threads_.end(),
                                    [this](auto& th) {
                                      using namespace std::chrono_literals;
                                      if (th.wait_for(0ns) == std::future_status::ready) {
                                        this->get_future(th);
                                        return true;
                                      } else {
                                        return false;
                                      }
                                    }),
                     threads_.end());
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename FutureReturnType = void>

virtual void ThreadController_NS::SimpleThreadController< FutureReturnType >::finish ( )

inlinevirtual

Definition at line 74 of file ThreadController.h.

References ThreadController_NS::SimpleThreadController< FutureReturnType >::get_future(), and ThreadController_NS::SimpleThreadController< FutureReturnType >::threads_.

Referenced by anonymous_namespace{TableArchiver.cpp}::update_or_drop_column_ids_in_table_files().

                        {
    for (auto& t : threads_) {
      get_future(t);
    }
    threads_.clear();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename FutureReturnType = void>

template<bool future_return_void = std::is_void<FutureReturnType>::value>

void ThreadController_NS::SimpleThreadController< FutureReturnType >::get_future ( std::future< FutureReturnType > &  future, std::enable_if_t< future_return_void > *  = 0  )

inlineprotected

Definition at line 83 of file ThreadController.h.

Referenced by ThreadController_NS::SimpleThreadController< FutureReturnType >::checkThreadsStatus(), and ThreadController_NS::SimpleThreadController< FutureReturnType >::finish().

                                                           {
    future.get();
  }

Here is the caller graph for this function:

template<typename FutureReturnType = void>

template<bool future_return_void = std::is_void<FutureReturnType>::value>

void ThreadController_NS::SimpleThreadController< FutureReturnType >::get_future ( std::future< FutureReturnType > &  future, std::enable_if_t<!future_return_void > *  = 0  )

inlineprotected

Definition at line 88 of file ThreadController.h.

References ThreadController_NS::SimpleThreadController< FutureReturnType >::future_getter_.

                                                            {
    future_getter_.get(future.get());
  }

template<typename FutureReturnType = void>

virtual int ThreadController_NS::SimpleThreadController< FutureReturnType >::getRunningThreadCount ( ) const

inlinevirtual

Reimplemented in ThreadController_NS::SimpleRunningThreadController< FutureReturnType >.

Definition at line 52 of file ThreadController.h.

References ThreadController_NS::SimpleThreadController< FutureReturnType >::threads_.

Referenced by ThreadController_NS::SimpleThreadController< FutureReturnType >::checkThreadsStatus().

{ return threads_.size(); }

Here is the caller graph for this function:

template<typename FutureReturnType = void>

virtual int ThreadController_NS::SimpleThreadController< FutureReturnType >::getThreadCount ( ) const

inlinevirtual

Definition at line 51 of file ThreadController.h.

References ThreadController_NS::SimpleThreadController< FutureReturnType >::threads_.

{ return threads_.size(); }

template<typename FutureReturnType = void>

template<typename FuncType , typename... Args>

void ThreadController_NS::SimpleThreadController< FutureReturnType >::startThread ( FuncType &&  func, Args &&...  args  )

inline

Definition at line 71 of file ThreadController.h.

References run_benchmark_import::args, threading_serial::async(), and ThreadController_NS::SimpleThreadController< FutureReturnType >::threads_.

Referenced by ThreadController_NS::SimpleRunningThreadController< FutureReturnType >::startThread(), and anonymous_namespace{TableArchiver.cpp}::update_or_drop_column_ids_in_table_files().

                                                    {
    threads_.emplace_back(std::async(std::launch::async, func, args...));
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

template<typename FutureReturnType = void>

const FutureGetter<FutureReturnType> ThreadController_NS::SimpleThreadController< FutureReturnType >::future_getter_ {}

private

Definition at line 95 of file ThreadController.h.

Referenced by ThreadController_NS::SimpleThreadController< FutureReturnType >::get_future().

template<typename FutureReturnType = void>

const int ThreadController_NS::SimpleThreadController< FutureReturnType >::max_threads_

private

Definition at line 94 of file ThreadController.h.

Referenced by ThreadController_NS::SimpleThreadController< FutureReturnType >::checkThreadsStatus().

template<typename FutureReturnType = void>

std::vector<std::future<FutureReturnType> > ThreadController_NS::SimpleThreadController< FutureReturnType >::threads_

private

Definition at line 96 of file ThreadController.h.

Referenced by ThreadController_NS::SimpleThreadController< FutureReturnType >::checkThreadsStatus(), ThreadController_NS::SimpleThreadController< FutureReturnType >::finish(), ThreadController_NS::SimpleThreadController< FutureReturnType >::getRunningThreadCount(), ThreadController_NS::SimpleThreadController< FutureReturnType >::getThreadCount(), and ThreadController_NS::SimpleThreadController< FutureReturnType >::startThread().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/Shared/ThreadController.h