/* === S Y N F I G ========================================================= */
/*! \file threadpool.h
** \brief ThreadPool Header
**
** $Id$
**
** \legal
** ......... ... 2018 Ivan Mahonin
**
** This package is free software; you can redistribute it and/or
** modify it under the terms of the GNU General Public License as
** published by the Free Software Foundation; either version 2 of
** the License, or (at your option) any later version.
**
** This package is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
** General Public License for more details.
** \endlegal
*/
/* ========================================================================= */
/* === S T A R T =========================================================== */
#ifndef __SYNFIG_THREADPOOL_H
#define __SYNFIG_THREADPOOL_H
/* === H E A D E R S ======================================================= */
#include <atomic>
#include <queue>
#include <sigc++/signal.h>
#include <glibmm/threads.h>
#include "real.h"
/* === M A C R O S ========================================================= */
/* === T Y P E D E F S ===================================================== */
/* === C L A S S E S & S T R U C T S ======================================= */
namespace synfig {
class ThreadPool {
public:
typedef sigc::slot<void> Slot;
class Group {
public:
typedef std::pair<Real, Slot> Entry;
typedef std::vector<Entry> List;
private:
bool multithreading;
std::atomic<int> running_threads;
Glib::Threads::Mutex mutex;
Glib::Threads::Cond cond;
List tasks;
Real sum_weight;
void process(int begin, int end);
public:
Group();
~Group();
void enqueue(const Slot &slot, Real weight = 1.0);
void run(bool force_thread = false);
};
private:
Glib::Threads::Mutex mutex;
Glib::Threads::Cond cond;
int max_running_threads;
std::atomic<int> running_threads;
std::atomic<int> ready_threads;
std::atomic<int> queue_size;
std::queue<Slot> queue;
std::vector<Glib::Threads::Thread*> threads;
bool stopped;
void thread_loop(int index);
void wakeup();
ThreadPool();
ThreadPool(const ThreadPool&);
public:
static ThreadPool instance;
~ThreadPool();
void enqueue(const Slot &slot);
void wait(Glib::Threads::Cond &cond, Glib::Threads::Mutex &mutex);
int get_max_threads() const
{ return max_running_threads; }
int get_running_threads() const
{ return running_threads; }
int get_queue_size() const
{ return queue_size + running_threads; }
};
}; // END of namespace synfig
/* === E N D =============================================================== */
#endif