diff options
author | Rob Pike <r@golang.org> | 2008-09-16 11:00:11 -0700 |
---|---|---|
committer | Rob Pike <r@golang.org> | 2008-09-16 11:00:11 -0700 |
commit | f14d65d21b2583798feca40b7075c5a2419f72f5 (patch) | |
tree | 9e3273345700a339607c4a1a5e0d198f71b21523 /doc/progs/server.go | |
parent | b0f3941771e69ea0aa784d41c7da8d9590fda41e (diff) | |
download | golang-f14d65d21b2583798feca40b7075c5a2419f72f5.tar.gz |
replace 235 with sieve - less problematic
add programs, not yet described, to demonstrate servers.
R=gri
DELTA=279 (177 added, 16 deleted, 86 changed)
OCL=15380
CL=15389
Diffstat (limited to 'doc/progs/server.go')
-rw-r--r-- | doc/progs/server.go | 49 |
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"); +} |