diff options
author | tomsmeding <tom.smeding@gmail.com> | 2018-08-29 22:51:58 +0200 |
---|---|---|
committer | tomsmeding <tom.smeding@gmail.com> | 2018-08-29 22:51:58 +0200 |
commit | 34ab0451bdd1e7496d607acb6ee209586ee7e86e (patch) | |
tree | adf3a587581418bf381fd3b98f38fc55d192b0f2 /job.h | |
parent | 9da9ab3e4517328ffe0fd0aaf23e2056b705ad76 (diff) |
Rename job.{cpp,h} to scheduler
Diffstat (limited to 'job.h')
-rw-r--r-- | job.h | 40 |
1 files changed, 0 insertions, 40 deletions
@@ -1,40 +0,0 @@ -#pragma once - -#include <functional> -#include <queue> -#include <vector> -#include <thread> -#include <mutex> - -using namespace std; - - -class Scheduler { - struct Job { - function<void()> callback; - - Job(const function<void()> callback) - : callback(callback) {} - }; - - queue<Job*> jobs; - bool finishFlag = false; - mutex commMut; - - bool hasJoined = false; - - vector<thread> workers; - - void workerEntry(); - -public: - const int nthreads; - - Scheduler(int nthreads); - ~Scheduler(); - - // func is run in child thread - void submit(const function<void()> &func); - - void finish(); -}; |