From 20d28e80a5c861a9d5f449ea911ab75b4f37ad0d Mon Sep 17 00:00:00 2001
From: Jef <jef@targetspot.com>
Date: Tue, 24 Sep 2024 14:54:57 +0200
Subject: Initial community commit

---
 Src/nu/threadpool/ThreadFunctions.h | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)
 create mode 100644 Src/nu/threadpool/ThreadFunctions.h

(limited to 'Src/nu/threadpool/ThreadFunctions.h')

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