Import sources from 2011-03-30 iso image

1 files changed, 85 insertions, 0 deletions

diff --git a/sys/src/libthread/example.c b/sys/src/libthread/example.c
new file mode 100755
index 000000000..dcef548a5
--- /dev/null
+++ b/sys/src/libthread/example.c
@@ -0,0 +1,85 @@
+/*
+Threadmain spawns two subprocesses, one
+to read the mouse, and one to receive
+timer events.  The events are sent via a
+channel to the main proc which prints a
+word when an event comes in.  When mouse
+button three is pressed, the application
+terminates.
+*/
+
+#include <u.h>
+#include <libc.h>
+#include <thread.h>
+
+enum
+{
+	STACK = 2048,
+};
+
+void
+mouseproc(void *arg)
+{
+	char m[48];
+	int mfd;
+	Channel *mc;
+
+	mc = arg;
+	if((mfd = open("/dev/mouse", OREAD)) < 0)
+		sysfatal("open /dev/mouse: %r");
+	for(;;){
+		if(read(mfd, m, sizeof m) != sizeof m)
+			sysfatal("eof");
+		if(atoi(m+1+2*12)&4)
+			sysfatal("button 3");
+		send(mc, m);
+	}
+}
+
+void
+clockproc(void *arg)
+{
+	int t;
+	Channel *c;
+
+	c = arg;
+	for(t=0;; t++){
+		sleep(1000);
+		sendul(c, t);
+	}
+}
+
+
+void
+threadmain(int argc, char *argv[])
+{
+	char m[48];
+	int t;
+	Alt a[] = {
+	/*	 c		v		op   */
+		{nil,	m,	CHANRCV},
+		{nil,	&t,	CHANRCV},
+		{nil,	nil,	CHANEND},
+	};
+
+	/* create mouse event channel and mouse process */
+	a[0].c = chancreate(sizeof m, 0);
+	proccreate(mouseproc, a[0].c, STACK);
+
+	/* create clock event channel and clock process */
+	a[1].c = chancreate(sizeof(ulong), 0);	/* clock event channel */
+	proccreate(clockproc, a[1].c, STACK);
+
+	for(;;){
+		switch(alt(a)){
+		case 0:	/*mouse event */
+			fprint(2, "click ");
+			break;
+		case 1:	/* clock event */
+			fprint(2, "tic ");
+			break;
+		default:
+			sysfatal("can't happen");
+		}
+	}
+}