Initial community commit

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;
+};