blob: 1bc7c148e136f5a530d5d0cf81edb4a8bf1e916e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
#pragma once
#include <deque>
#include <functional>
#include <future>
#include <memory>
#include <mutex>
#include <semaphore>
#include <special_members.hpp>
#include <thread>
#include <utility>
#include <vector>
class Worker {
public:
class WorkItem {
public:
WorkItem() = default;
virtual ~WorkItem() = default;
NO_MOVE(WorkItem);
NO_COPY(WorkItem);
virtual void doWork() = 0;
};
template<typename T> class WorkItemT : public WorkItem {
public:
T
get()
{
return future.get();
}
protected:
std::promise<T> promise;
std::future<T> future {promise.get_future()};
friend Worker;
};
template<typename... Params>
static auto
addWork(Params &&... params)
{
return instance.addWorkImpl(std::forward<Params>(params)...);
}
template<typename T> using WorkPtrT = std::shared_ptr<WorkItemT<T>>;
private:
template<typename T, typename... Params> class WorkItemTImpl : public WorkItemT<T> {
public:
WorkItemTImpl(Params &&... params) : params {std::forward<Params>(params)...} { }
private:
void
doWork() override
{
try {
if constexpr (std::is_void_v<T>) {
std::apply(std::invoke<Params &...>, params);
WorkItemT<T>::promise.set_value();
}
else {
WorkItemT<T>::promise.set_value(std::apply(std::invoke<Params &...>, params));
}
}
catch (...) {
WorkItemT<T>::promise.set_exception(std::current_exception());
}
}
std::tuple<Params...> params;
};
Worker();
~Worker();
NO_COPY(Worker);
NO_MOVE(Worker);
using WorkPtr = std::shared_ptr<WorkItem>;
template<typename... Params>
auto
addWorkImpl(Params &&... params)
{
using T = decltype(std::invoke(std::forward<Params>(params)...));
auto work = std::make_shared<WorkItemTImpl<T, Params...>>(std::forward<Params>(params)...);
addWorkPtr(work);
return work;
}
void addWorkPtr(WorkPtr w);
void worker();
using Threads = std::vector<std::jthread>;
using ToDo = std::deque<WorkPtr>;
ToDo todo;
std::counting_semaphore<16> todoLen;
std::mutex todoMutex;
Threads threads;
static Worker instance;
};
|
