From 7a172be6213839a3d023ba21c3bafd7540a4bfe8 Mon Sep 17 00:00:00 2001 From: Bruce Hill Date: Mon, 31 Mar 2025 02:11:03 -0400 Subject: Remove threads and mutexed data from the language in favor of a module-based approach --- src/stdlib/threads.c | 92 ---------------------------------------------------- 1 file changed, 92 deletions(-) delete mode 100644 src/stdlib/threads.c (limited to 'src/stdlib/threads.c') diff --git a/src/stdlib/threads.c b/src/stdlib/threads.c deleted file mode 100644 index 05f5a941..00000000 --- a/src/stdlib/threads.c +++ /dev/null @@ -1,92 +0,0 @@ -// Logic for the Thread type, representing a pthread - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -#include "arrays.h" -#include "datatypes.h" -#include "metamethods.h" -#include "rng.h" -#include "text.h" -#include "threads.h" -#include "types.h" -#include "util.h" - -#if defined(__FreeBSD__) || defined(__OpenBSD__) || defined(__NetBSD__) || defined(__APPLE__) -static ssize_t getrandom(void *buf, size_t buflen, unsigned int flags) { - (void)flags; - arc4random_buf(buf, buflen); - return buflen; -} -#elif defined(__linux__) -// Use getrandom() -# include -#else - #error "Unsupported platform for secure random number generation" -#endif - -static void *run_thread(Closure_t *closure) -{ - uint8_t *random_bytes = GC_MALLOC_ATOMIC(40); - getrandom(random_bytes, 40, 0); - Array_t rng_seed = {.length=40, .data=random_bytes, .stride=1, .atomic=1}; - default_rng = RNG$new(rng_seed); - ((void(*)(void*))closure->fn)(closure->userdata); - return NULL; -} - -public Thread_t Thread$new(Closure_t fn) -{ - Thread_t thread = GC_MALLOC(sizeof(pthread_t)); - Closure_t *closure = new(Closure_t, .fn=fn.fn, .userdata=fn.userdata); - pthread_create(thread, NULL, (void*)run_thread, closure); - return thread; -} - -public void Thread$join(Thread_t thread) -{ - pthread_join(*thread, NULL); -} - -public void Thread$cancel(Thread_t thread) -{ - pthread_cancel(*thread); -} - -public void Thread$detach(Thread_t thread) -{ - pthread_detach(*thread); -} - -Text_t Thread$as_text(const void *thread, bool colorize, const TypeInfo_t*) -{ - if (!thread) { - return colorize ? Text("\x1b[34;1mThread\x1b[m") : Text("Thread"); - } - return Text$format(colorize ? "\x1b[34;1mThread(%p)\x1b[m" : "Thread(%p)", *(Thread_t**)thread); -} - -static bool Thread$is_none(const void *obj, const TypeInfo_t*) -{ - return *(Thread_t*)obj == NULL; -} - -public const TypeInfo_t Thread$info = { - .size=sizeof(Thread_t), .align=__alignof(Thread_t), - .metamethods={ - .as_text=Thread$as_text, - .is_none=Thread$is_none, - .serialize=cannot_serialize, - .deserialize=cannot_deserialize, - }, -}; - -// vim: ts=4 sw=0 et cino=L2,l1,(0,W4,m1,\:0 -- cgit v1.2.3