ref: 9f4d2e578fa2b874d65fd85d28f9b9f31e88dd0f
parent: beca6100b73428b4b72973275d2989a4c6581f51
author: rodri <rgl@antares-labs.eu>
date: Tue Sep 17 11:35:48 EDT 2024
forgot turbopool.c
--- /dev/null
+++ b/turbopool.c
@@ -1,0 +1,60 @@
+#include <u.h>
+#include <libc.h>
+#include <thread.h>
+#include <draw.h>
+#include <memdraw.h>
+#include <geometry.h>
+#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);
+}