59 lines
798 B
C
59 lines
798 B
C
#include <u.h>
|
|
#include <libc.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, 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);
|
|
}
|