From e5888a1ffdae813d7575f5fb02275c6bb07e5199 Mon Sep 17 00:00:00 2001 From: Taru Karttunen Date: Wed, 30 Mar 2011 15:46:40 +0300 Subject: Import sources from 2011-03-30 iso image --- sys/src/libthread/tprimes.c | 58 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 58 insertions(+) create mode 100755 sys/src/libthread/tprimes.c (limited to 'sys/src/libthread/tprimes.c') diff --git a/sys/src/libthread/tprimes.c b/sys/src/libthread/tprimes.c new file mode 100755 index 000000000..50ab63996 --- /dev/null +++ b/sys/src/libthread/tprimes.c @@ -0,0 +1,58 @@ +#include +#include +#include + +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, 1024); + for(;;){ + i = recvul(c); + if(i%p) + sendul(nc, i); + } +} + +void +threadmain(int argc, char **argv) +{ + int i; + Channel *c; + + ARGBEGIN{ + 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); + threadcreate(primethread, c, 1024); + for(i=2;; i++) + sendul(c, i); +} -- cgit v1.2.3