bunkum

commit 3576211e4e1822a07fca3d2342427229726287d3
parent cc9debcf1492a32d26676902610025bee53d6e40
Author: quantumish <freifeld.david@gmail.com>
Date:   Sat, 15 Apr 2023 14:32:59 -0700

Questionable channel implementation

Diffstat:
A
utils/sync.c
 | 
43
+++++++++++++++++++++++++++++++++++++++++++

1 file changed, 43 insertions(+), 0 deletions(-)
diff --git a/utils/sync.c b/utils/sync.c
@@ -0,0 +1,43 @@
+
+
+#include <pthread.h>
+#include "shitvec.h"
+
+
+typedef struct channel {
+    pthread_mutex_t mutex;
+    shitvec_t queue;
+    size_t msg_sz;
+    size_t sz;
+} channel_t;
+
+
+channel_t channel_new(size_t msg_sz) {
+    channel_t out;
+    out.msg_sz = msg_sz;
+    pthread_mutex_init(&out.mutex, NULL);
+    out.queue = shitvec_new(msg_sz);
+    out.sz = 0;
+}
+
+void channel_push(channel_t* chan, void* msg) {
+    pthread_mutex_lock(&chan->mutex);
+	shitvec_push(&chan->queue, msg);
+	pthread_mutex_unlock(&chan->mutex);
+	__atomic_fetch_add(&chan->sz, 1, __ATOMIC_RELAXED);
+}
+
+void* channel_pop(channel_t* chan) {
+	void* out;
+	pthread_mutex_lock(&chan->mutex);
+	out = shitvec_get(&chan->queue, chan->queue.vec_sz-1);
+	chan->queue.vec_sz -= 1;
+	pthread_mutex_unlock(&chan->mutex);
+	__atomic_fetch_sub(&chan->sz, 1, __ATOMIC_RELAXED);
+	return out;
+}
+
+void* channel_recv(channel_t * chan) {
+	while (__atomic_load_n(&chan->sz, __ATOMIC_RELAXED) == 0);
+	return channel_pop(chan);	
+}