Add queue implementation

2026-01-11 23:46:23 +00:00
parent 9af9cedd51
commit a9f5b9c3c6
9 changed files with 245 additions and 1 deletions
--- a/src/base/queue/queue.h
+++ b/src/base/queue/queue.h
@@ -0,0 +1,81 @@
+// vim:fileencoding=utf-8:foldmethod=marker
+
+#ifndef QUEUE_H
+#define QUEUE_H
+
+#include "../array/array.h"
+#include "../../common/aliases/aliases.h"
+#include "../../common/platform/platform.h"
+
+#ifdef WAPP_PLATFORM_CPP
+BEGIN_C_LINKAGE
+#endif // !WAPP_PLATFORM_CPP
+
+typedef struct {
+	GenericArray items;
+} GenericQueue;
+
+// NOTE (Abdelrahman): GenericQueue typedefs for readability
+typedef GenericQueue VoidPtrQueue;
+typedef GenericQueue C8Queue;
+typedef GenericQueue C16Queue;
+typedef GenericQueue C32Queue;
+typedef GenericQueue U8Queue;
+typedef GenericQueue U16Queue;
+typedef GenericQueue U32Queue;
+typedef GenericQueue U64Queue;
+typedef GenericQueue B8Queue;
+typedef GenericQueue I8Queue;
+typedef GenericQueue I16Queue;
+typedef GenericQueue I32Queue;
+typedef GenericQueue I64Queue;
+typedef GenericQueue F32Queue;
+typedef GenericQueue F64Queue;
+typedef GenericQueue F128Queue;
+typedef GenericQueue UptrQueue;
+typedef GenericQueue IptrQueue;
+typedef GenericQueue Str8Queue;
+
+#ifdef WAPP_PLATFORM_CPP
+#define wapp_queue(TYPE, CAPACITY) ([&]() {                                                        \
+	wapp_persist GenericArray arr   = wapp_array_with_capacity(TYPE, CAPACITY, ARRAY_INIT_NONE);     \
+	wapp_persist GenericQueue queue = {arr};                                                         \
+                                                                                                   \
+	return queue;                                                                                    \
+}())
+#define wapp_queue_alloc(TYPE, ALLOCATOR_PTR, CAPACITY) ([&]() {                                   \
+	wapp_persist GenericQueue queue = {                                                              \
+		wapp_array_alloc_capacity(TYPE, ALLOCATOR_PTR, CAPACITY, ARRAY_INIT_NONE)                      \
+	};                                                                                               \
+                                                                                                   \
+	return queue;                                                                                    \
+}())
+#else
+#define wapp_queue(TYPE, CAPACITY) ((GenericQueue){                                                \
+	.items = wapp_array_with_capacity(TYPE, CAPACITY, ARRAY_INIT_NONE)                               \
+})
+#define wapp_queue_alloc(TYPE, ALLOCATOR_PTR, CAPACITY) ((GenericQueue){                           \
+	.items = wapp_array_alloc_capacity(TYPE, ALLOCATOR_PTR, CAPACITY, ARRAY_INIT_NONE)               \
+})
+#endif // !WAPP_PLATFORM_CPP
+
+#define wapp_queue_count(QUEUE_PTR) (wapp_array_count((QUEUE_PTR)->items))
+#define wapp_queue_capacity(QUEUE_PTR) (wapp_array_capacity((QUEUE_PTR)->items))
+#define wapp_queue_item_size(QUEUE_PTR) (wapp_array_item_size((QUEUE_PTR)->items))
+#define wapp_queue_push_back(TYPE, QUEUE_PTR, VALUE_PTR) (                                         \
+	wapp_array_append_capped(TYPE, (QUEUE_PTR)->items, VALUE_PTR)                                    \
+)
+#define wapp_queue_push_back_alloc(TYPE, ALLOCATOR_PTR, QUEUE_PTR, VALUE_PTR) (                    \
+	wapp_array_append_alloc(TYPE, ALLOCATOR_PTR, (QUEUE_PTR)->items, VALUE_PTR)                      \
+)
+#define wapp_queue_pop_front(TYPE, QUEUE_PTR, OUTPUT_PTR) (                                        \
+	_queue_pop_front(QUEUE_PTR, OUTPUT_PTR, sizeof(TYPE))                                            \
+)
+
+void _queue_pop_front(GenericQueue *queue, void *output, u64 item_size);
+
+#ifdef WAPP_PLATFORM_CPP
+END_C_LINKAGE
+#endif // !WAPP_PLATFORM_CPP
+
+#endif // !QUEUE_H