-
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathdispatch_queue.cpp
More file actions
70 lines (57 loc) · 1.11 KB
/
Copy pathdispatch_queue.cpp
File metadata and controls
70 lines (57 loc) · 1.11 KB
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
#include "../include/dispatch_queue.hpp"
namespace dispatch_queue {
dispatch_queue::dispatch_queue()
{
}
dispatch_queue::dispatch_queue(int thread_count)
: dispatch_queue(thread_count, [](int){})
{
}
dispatch_queue::~dispatch_queue() {
shutdown();
}
bool dispatch_queue::is_threaded() const {
return worker_pool != nullptr;
}
int dispatch_queue::thread_count() const {
if (worker_pool) {
return worker_pool->thread_count();
}
else {
return 0;
}
}
size_t dispatch_queue::size() const {
if (worker_pool) {
return worker_pool->size();
}
else {
return 0;
}
}
bool dispatch_queue::empty() const {
return size() == 0;
}
void dispatch_queue::clear() {
if (worker_pool) {
worker_pool->clear();
}
}
void dispatch_queue::main_loop() {
std::deque<detail::pending_task> main_loop_tasks = worker_pool
? worker_pool->pop_main_loop_tasks()
: task_queue.pop_main_loop_tasks();
for (auto&& it : main_loop_tasks) {
it();
}
}
void dispatch_queue::wait() {
if (worker_pool) {
worker_pool->wait();
}
}
void dispatch_queue::shutdown() {
clear();
worker_pool.reset();
}
} // end namespace dispatch_queue