Merge branch 'main' into formatter

1 files changed, 0 insertions, 117 deletions

diff --git a/lib/pthreads/pthreads.tm b/lib/pthreads/pthreads.tm
deleted file mode 100644
index 8fca6bd6..00000000
--- a/lib/pthreads/pthreads.tm
+++ /dev/null
@@ -1,117 +0,0 @@
-# A Posix Threads (pthreads) wrapper
-use <pthread.h>
-
-struct pthread_mutex_t(; extern, opaque)
-    func new(->@pthread_mutex_t)
-        return C_code : @pthread_mutex_t(
-            pthread_mutex_t *mutex = GC_MALLOC(sizeof(pthread_mutex_t));
-            pthread_mutex_init(mutex, NULL);
-            GC_register_finalizer(mutex, (void*)pthread_mutex_destroy, NULL, NULL, NULL);
-            mutex
-        )
-
-    func lock(m:&pthread_mutex_t)
-        fail("Failed to lock mutex") unless C_code:Int32(pthread_mutex_lock(@m)) == 0
-
-    func unlock(m:&pthread_mutex_t)
-        fail("Failed to unlock mutex") unless C_code:Int32(pthread_mutex_unlock(@m)) == 0
-
-struct pthread_cond_t(; extern, opaque)
-    func new(->@pthread_cond_t)
-        return C_code : @pthread_cond_t(
-            pthread_cond_t *cond = GC_MALLOC(sizeof(pthread_cond_t));
-            pthread_cond_init(cond, NULL);
-            GC_register_finalizer(cond, (void*)pthread_cond_destroy, NULL, NULL, NULL);
-            cond
-        )
-
-    func wait(cond:&pthread_cond_t, mutex:&pthread_mutex_t)
-        fail("Failed to wait on condition") unless C_code:Int32(pthread_cond_wait(@cond, @mutex)) == 0
-
-    func signal(cond:&pthread_cond_t)
-        fail("Failed to signal pthread_cond_t") unless C_code:Int32(pthread_cond_signal(@cond)) == 0
-
-    func broadcast(cond:&pthread_cond_t)
-        fail("Failed to broadcast pthread_cond_t") unless C_code:Int32(pthread_cond_broadcast(@cond)) == 0
-
-struct pthread_rwlock_t(; extern, opaque)
-    func new(->@pthread_rwlock_t)
-        return C_code : @pthread_rwlock_t (
-            pthread_rwlock_t *lock = GC_MALLOC(sizeof(pthread_rwlock_t));
-            pthread_rwlock_init(lock, NULL);
-            GC_register_finalizer(lock, (void*)pthread_rwlock_destroy, NULL, NULL, NULL);
-            lock
-        )
-
-    func read_lock(lock:&pthread_rwlock_t)
-        C_code { pthread_rwlock_rdlock(@lock); }
-
-    func write_lock(lock:&pthread_rwlock_t)
-        C_code { pthread_rwlock_wrlock(@lock); }
-
-    func unlock(lock:&pthread_rwlock_t)
-        C_code { pthread_rwlock_unlock(@lock); }
-
-struct pthread_t(; extern, opaque)
-    func new(fn:func() -> @pthread_t)
-        return C_code:@pthread_t(
-            pthread_t *thread = GC_MALLOC(sizeof(pthread_t));
-            pthread_create(thread, NULL, @fn.fn, @fn.userdata);
-            thread
-        )
-
-    func join(p:pthread_t) C_code { pthread_join(@p, NULL); }
-    func cancel(p:pthread_t) C_code { pthread_cancel(@p); }
-    func detatch(p:pthread_t) C_code { pthread_detach(@p); }
-
-struct IntQueue(_queue:@[Int], _mutex:@pthread_mutex_t, _cond:@pthread_cond_t)
-    func new(initial:[Int]=[] -> IntQueue)
-        return IntQueue(@initial, pthread_mutex_t.new(), pthread_cond_t.new())
-
-    func give(q:IntQueue, n:Int)
-        do q._mutex.lock()
-            q._queue.insert(n)
-            q._mutex.unlock()
-        q._cond.signal()
-
-    func take(q:IntQueue -> Int)
-        do q._mutex.lock()
-            n := q._queue.pop(1)
-            while not n
-                q._cond.wait(q._mutex)
-                n = q._queue.pop(1)
-            q._mutex.unlock()
-            return n!
-
-func main()
-    jobs := IntQueue.new()
-    results := IntQueue.new()
-
-    say_mutex := pthread_mutex_t.new()
-    announce := func(speaker:Text, text:Text)
-        do say_mutex.lock()
-            say("\[2][$speaker]\[] $text")
-            say_mutex.unlock()
-
-    worker := pthread_t.new(func()
-        say("I'm in the thread!")
-        repeat
-            announce("worker", "waiting for job")
-            job := jobs.take()
-            result := job * 10
-            announce("worker", "Jobbing $job into $result")
-            results.give(result)
-            announce("worker", "Signaled $result")
-    )
-
-    for i in 10
-        announce("boss", "Pushing job $i")
-        jobs.give(i)
-        announce("boss", "Gave job $i")
-
-    for i in 10
-        announce("boss", "Getting result...")
-        result := results.take()
-        announce("boss", "Got result $result")
-
-    >> worker.cancel()