mirror of
https://github.com/golang/go
synced 2024-11-23 00:10:07 -07:00
50 lines
971 B
Go
50 lines
971 B
Go
// 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 request struct {
|
|
a, b int;
|
|
replyc chan int;
|
|
}
|
|
|
|
type binOp func(a, b int) int
|
|
|
|
func run(op binOp, req *request) {
|
|
reply := op(req.a, req.b);
|
|
req.replyc <- reply;
|
|
}
|
|
|
|
func server(op binOp, service chan *request) {
|
|
for {
|
|
req := <-service;
|
|
go run(op, req); // don't wait for it
|
|
}
|
|
}
|
|
|
|
func startServer(op binOp) chan *request {
|
|
req := make(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 = make(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");
|
|
}
|