diff options
Diffstat (limited to 'src/libthread/tprimes.c')
-rw-r--r-- | src/libthread/tprimes.c | 62 |
1 files changed, 62 insertions, 0 deletions
diff --git a/src/libthread/tprimes.c b/src/libthread/tprimes.c new file mode 100644 index 00000000..9426bdfa --- /dev/null +++ b/src/libthread/tprimes.c @@ -0,0 +1,62 @@ +#include <lib9.h> +#include <thread.h> + +int quiet; +int goal; +int buffer; +int (*fn)(void(*)(void*), void*, uint) = threadcreate; + +void +primethread(void *arg) +{ + Channel *c, *nc; + int p, i; + + c = arg; + p = recvul(c); + if(p > goal) + threadexitsall(nil); + if(!quiet) + print("%d\n", p); + nc = chancreate(sizeof(ulong), buffer); + (*fn)(primethread, nc, 8192); + for(;;){ + i = recvul(c); + if(i%p) + sendul(nc, i); + } +} + +extern int _threaddebuglevel; + +void +threadmain(int argc, char **argv) +{ + int i; + Channel *c; + + ARGBEGIN{ + case 'D': + _threaddebuglevel = atoi(ARGF()); + break; + case 'q': + quiet = 1; + break; + case 'b': + buffer = atoi(ARGF()); + break; + case 'p': + fn=proccreate; + break; + }ARGEND + + if(argc>0) + goal = atoi(argv[0]); + else + goal = 100; + + c = chancreate(sizeof(ulong), buffer); + (*fn)(primethread, c, 8192); + for(i=2;; i++) + sendul(c, i); +} |