BoundedThreadPool Class Reference

#include <BoundedThreadPool.hpp>

Public Member Functions
template<typename T >
void	push_task (const T &task)
template<typename T , typename... A>
void	push_task (const T &task, const A &...args)
void	wait_for_completion ()
void	join_threads ()
void	init (int n_threads, int limit)
	BoundedThreadPool (int n_threads)
	BoundedThreadPool (int n_threads, int limit)
	BoundedThreadPool ()
	~BoundedThreadPool ()

Public Attributes
int	n_threads
int	limit

Detailed Description

Definition at line 25 of file BoundedThreadPool.hpp.

Constructor & Destructor Documentation

BoundedThreadPool() [1/3]

BoundedThreadPool::BoundedThreadPool ( int  n_threads )

inlineexplicit

Definition at line 124 of file BoundedThreadPool.hpp.

                                              : limit(8)
    {
        init(n_threads, limit);
    }

BoundedThreadPool() [2/3]

BoundedThreadPool::BoundedThreadPool ( int  n_threads, int  limit  )

inlineexplicit

Definition at line 129 of file BoundedThreadPool.hpp.

    {
        init(n_threads, limit);
    }

BoundedThreadPool() [3/3]

BoundedThreadPool::BoundedThreadPool ( )

inline

Definition at line 134 of file BoundedThreadPool.hpp.

:  b_running(false), n_threads(0), limit(0) {}

~BoundedThreadPool()

BoundedThreadPool::~BoundedThreadPool ( )

inline

Definition at line 136 of file BoundedThreadPool.hpp.

    {
        wait_for_completion();
        b_running = false;
        cnd_buffer_empty.notify_all();
        join_threads();
    }

Member Function Documentation

init()

void BoundedThreadPool::init ( int  n_threads, int  limit  )

inline

Definition at line 108 of file BoundedThreadPool.hpp.

    {
        int n_threads_max = std::thread::hardware_concurrency();
        if (n_threads > n_threads_max || n_threads < 1)
        {
            this->n_threads = n_threads_max;
        }
        else
        {
            this->n_threads = n_threads;
        }
        this->limit = limit;
        b_running = true;
        create_threads();
    }

join_threads()

void BoundedThreadPool::join_threads ( )

inline

Definition at line 100 of file BoundedThreadPool.hpp.

    {
        for (int i = 0; i < n_threads; i++)
        {
            threads[i].join();
        }
    }

push_task() [1/2]

template<typename T >

void BoundedThreadPool::push_task ( const T &  task )

inline

Definition at line 77 of file BoundedThreadPool.hpp.

    {
        std::unique_lock<std::mutex> lock(mtx_queue);
        cnd_buffer_full.wait(lock, [this]
                             { return ((int)tasks.size() < limit); });
        tasks.push(std::function<void()>(task));
        cnd_buffer_empty.notify_one();
    }

push_task() [2/2]

template<typename T , typename... A>

void BoundedThreadPool::push_task ( const T &  task, const A &...  args  )

inline

Definition at line 87 of file BoundedThreadPool.hpp.

    {
        push_task([task, args...]
                  { task(args...); });
    }

wait_for_completion()

void BoundedThreadPool::wait_for_completion ( )

inline

Definition at line 93 of file BoundedThreadPool.hpp.

    {
        std::unique_lock<std::mutex> lock(mtx_queue);
        cnd_buffer_full.wait(lock, [this]
                             { return tasks.empty(); });
    }

Member Data Documentation

limit

int BoundedThreadPool::limit

Definition at line 74 of file BoundedThreadPool.hpp.

n_threads

int BoundedThreadPool::n_threads

Definition at line 73 of file BoundedThreadPool.hpp.

---

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

• src/BoundedThreadPool.hpp