From 20d28e80a5c861a9d5f449ea911ab75b4f37ad0d Mon Sep 17 00:00:00 2001 From: Jef Date: Tue, 24 Sep 2024 14:54:57 +0200 Subject: Initial community commit --- Src/nu/ThreadQueue.h | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 Src/nu/ThreadQueue.h (limited to 'Src/nu/ThreadQueue.h') 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 + +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; +}; + -- cgit