From c0406348f61fa98db45e9f53dfb364bc813363a4 Mon Sep 17 00:00:00 2001 From: stephen mcquay Date: Fri, 26 Jan 2018 17:15:13 -0800 Subject: [PATCH] make client concurrent --- cmd/hwtc/main.go | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/cmd/hwtc/main.go b/cmd/hwtc/main.go index da462dc..282e362 100644 --- a/cmd/hwtc/main.go +++ b/cmd/hwtc/main.go @@ -32,12 +32,17 @@ func main() { os.Exit(1) } + s := make(chan bool, 10) for i := 0; ; i++ { - resp, err := c.Hello(ctx, &pb.HelloReq{Subject: strings.Join(os.Args[2:], " ")}) - if err != nil { - fmt.Fprintf(os.Stderr, "hello: %#v\n", err) - os.Exit(1) - } - fmt.Printf("0x%08x: %#v\n", i, resp) + s <- true + go func(j int) { + resp, err := c.Hello(ctx, &pb.HelloReq{Subject: strings.Join(os.Args[2:], " ")}) + if err != nil { + fmt.Fprintf(os.Stderr, "hello: %#v\n", err) + os.Exit(1) + } + fmt.Printf("0x%08x: %#v\n", j, resp) + <-s + }(i) } }