blob: 1fc53bcf4005e1291b36776758b85d863d5489f1 (
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
105
|
#ifndef ENV_ENVFS_H
#define ENV_ENVFS_H
#include <thread>
namespace env
{
struct File
{
std::wstring name;
FILETIME ft;
};
struct Directory
{
std::wstring name;
std::list<Directory> dirs;
std::list<File> files;
};
template <class T>
class ThreadPool
{
public:
ThreadPool(std::size_t max=1)
: m_threads(max)
{
}
~ThreadPool()
{
join();
}
void setMax(std::size_t n)
{
m_threads.resize(n);
}
void join()
{
for (auto& ti : m_threads) {
if (ti.thread.joinable()) {
ti.thread.join();
}
}
}
T& request()
{
if (m_threads.empty()) {
std::terminate();
}
for (;;) {
for (auto& ti : m_threads) {
bool expected = false;
if (ti.busy.compare_exchange_strong(expected, true)) {
if (ti.thread.joinable()) {
ti.thread.join();
}
ti.thread = std::thread([&]{
ti.o.run();
ti.busy = false;
});
return ti.o;
}
}
std::this_thread::sleep_for(std::chrono::milliseconds(1));
}
}
private:
struct ThreadInfo
{
std::thread thread;
std::atomic<bool> busy;
T o;
};
std::list<ThreadInfo> m_threads;
};
using DirStartF = void (void*, std::wstring_view);
using DirEndF = void (void*, std::wstring_view);
using FileF = void (void*, std::wstring_view, FILETIME);
void setHandleCloserThreadCount(std::size_t n);
void forEachEntry(
const std::wstring& path, void* cx,
DirStartF* dirStartF, DirEndF* dirEndF, FileF* fileF);
Directory getFilesAndDirs(const std::wstring& path);
} // namespace
#endif // ENV_ENVFS_H
|
