- Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathexample.cpp
More file actions
Latest commit
25 lines (21 loc) · 707 Bytes
/
Copy pathexample.cpp
File metadata and controls
25 lines (21 loc) · 707 Bytes
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
#include"threadpool.hpp"
#include<iostream>
#include<memory>
#include<mutex>
intmain() {
tp::ThreadPool threadpool; // Create a threadpool
std::mutex mutex;
std::vector<std::shared_ptr<tp::Task>> tasks; // Vector to store threadpool tasks
for (unsignedint i = 0; i < 10; ++i) {
tasks.push_back(threadpool.schedule([i, &mutex](void*) {
mutex.lock();
std::cout << "Printing from task: " << i << std::endl;
mutex.unlock();
})); // Schedule tasks and add them to the vector
}
for (constauto& task : tasks) { // Wait on every task
task->await();
}
std::cout << "All tasks done!" << std::endl;
return0;
}