Initial community commit

1 files changed, 23 insertions, 0 deletions

diff --git a/Src/nu/ThreadQueue.h b/Src/nu/ThreadQueue.h
new file mode 100644
index 00000000..0fc9fb23
--- /dev/null
+++ b/Src/nu/ThreadQueue.h
@@ -0,0 +1,23 @@
+#pragma once
+#include "RingBuffer.h"
+#include <semaphore.h>
+
+class ThreadQueue
+{
+public:
+	ThreadQueue();
+	~ThreadQueue();
+	void Queue(const void *);
+	// Get() blocks until there's something in the queue
+	void *Get();
+	// return value is same as sem_wait
+	// delay is in nanoseconds
+	int Wait(long delay, void **val);
+	// kind of like sem_trywait
+	int Try(void **val);
+private:
+	// TODO: need to use something safer than RingBuffer, preferably a lock-free linked list so we can grow unlimited
+	 RingBuffer buffer;
+	sem_t event;
+};
+