From 2fd16cbf190d5c37fc627f79bf586f66129fea46 Mon Sep 17 00:00:00 2001 From: rodri Date: Thu, 19 Sep 2024 21:33:17 +0000 Subject: get rid of the turbopool (the experiment was futile.) --- turbopool.c | 60 ------------------------------------------------------------ 1 file changed, 60 deletions(-) delete mode 100644 turbopool.c (limited to 'turbopool.c') diff --git a/turbopool.c b/turbopool.c deleted file mode 100644 index 8011c18..0000000 --- a/turbopool.c +++ /dev/null @@ -1,60 +0,0 @@ -#include -#include -#include -#include -#include -#include -#include "libobj/obj.h" -#include "graphics.h" -#include "internal.h" - -static void -_turboproc(void *arg) -{ - Turbopool *p; - Turbotask *t; - - threadsetname("turboproc"); - - p = arg; - - while((t = recvp(p->subq)) != nil){ - t->fn(t->arg); - free(t); - } -} - -Turbopool * -mkturbopool(ulong nprocs) -{ - Turbopool *p; - - p = emalloc(sizeof *p); - memset(p, 0, sizeof *p); - p->nprocs = nprocs; - p->subq = chancreate(sizeof(void*), nprocs); - while(nprocs--) - proccreate(_turboproc, p, mainstacksize); - return p; -} - -void -turbopoolexec(Turbopool *p, void (*fn)(void*), void *arg) -{ - Turbotask *t; - - t = emalloc(sizeof *t); - t->fn = fn; - t->arg = arg; - - sendp(p->subq, t); -} - -void -rmturbopool(Turbopool *p) -{ - while(p->nprocs--) - sendp(p->subq, nil); - chanfree(p->subq); - free(p); -} -- cgit v1.2.3