summaryrefslogtreecommitdiff
path: root/doc/progs/server.go
diff options
context:
space:
mode:
Diffstat (limited to 'doc/progs/server.go')
-rw-r--r--doc/progs/server.go49
1 files changed, 49 insertions, 0 deletions
diff --git a/doc/progs/server.go b/doc/progs/server.go
new file mode 100644
index 000000000..3f64e9df0
--- /dev/null
+++ b/doc/progs/server.go
@@ -0,0 +1,49 @@
+// Copyright 2009 The Go Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style
+// license that can be found in the LICENSE file.
+
+package main
+
+type BinOp (a, b int) int;
+
+type Request struct {
+ a, b int;
+ replyc *chan int;
+}
+
+func Run(op *BinOp, request *Request) {
+ result := op(request.a, request.b);
+ request.replyc -< result;
+}
+
+func Server(op *BinOp, service *chan *Request) {
+ for {
+ request := <-service;
+ go Run(op, request); // don't wait for it
+ }
+}
+
+func StartServer(op *BinOp) *chan *Request {
+ req := new(chan *Request);
+ go Server(op, req);
+ return req;
+}
+
+func main() {
+ adder := StartServer(func(a, b int) int { return a + b });
+ const N = 100;
+ var reqs [N]Request;
+ for i := 0; i < N; i++ {
+ req := &reqs[i];
+ req.a = i;
+ req.b = i + N;
+ req.replyc = new(chan int);
+ adder -< req;
+ }
+ for i := N-1; i >= 0; i-- { // doesn't matter what order
+ if <-reqs[i].replyc != N + 2*i {
+ print("fail at ", i, "\n");
+ }
+ }
+ print("done\n");
+}