aboutsummaryrefslogtreecommitdiff
path: root/Src/nu/threadpool/ThreadFunctions.h
diff options
context:
space:
mode:
Diffstat (limited to 'Src/nu/threadpool/ThreadFunctions.h')
-rw-r--r--Src/nu/threadpool/ThreadFunctions.h31
1 files changed, 31 insertions, 0 deletions
diff --git a/Src/nu/threadpool/ThreadFunctions.h b/Src/nu/threadpool/ThreadFunctions.h
new file mode 100644
index 00000000..bbc5e6c6
--- /dev/null
+++ b/Src/nu/threadpool/ThreadFunctions.h
@@ -0,0 +1,31 @@
+#pragma once
+#include "api_threadpool.h"
+#include <map>
+#include <deque>
+#include "../AutoLock.h"
+
+class ThreadFunctions
+{
+public:
+ struct Data
+ {
+ api_threadpool::ThreadPoolFunc func;
+ void *user_data;
+ intptr_t id;
+ };
+ ThreadFunctions(int create_function_list=1);
+ ~ThreadFunctions();
+ void Add(HANDLE handle, api_threadpool::ThreadPoolFunc func, void *user_data, intptr_t id);
+ bool Get(HANDLE handle, api_threadpool::ThreadPoolFunc *func, void **user_data, intptr_t *id);
+ void QueueFunction(api_threadpool::ThreadPoolFunc func, void *user_data, intptr_t id);
+ bool PopFunction(api_threadpool::ThreadPoolFunc *func, void **user_data, intptr_t *id);
+
+ typedef std::map<HANDLE, const ThreadFunctions::Data*> DataMap;
+ DataMap data;
+ Nullsoft::Utility::LockGuard guard;
+
+ typedef std::deque<ThreadFunctions::Data*> FuncList;
+ FuncList functions_list;
+ CRITICAL_SECTION functions_guard;
+ HANDLE functions_semaphore;
+};