From 3d61c7694b6815f0075c12c4b0565903989f1974 Mon Sep 17 00:00:00 2001 From: ouqiang Date: Mon, 26 Jun 2017 18:07:56 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dmap=E5=8A=A0=E9=94=81?= =?UTF-8?q?=E6=97=A0=E6=95=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/rpc/grpcpool/grpc_pool.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/modules/rpc/grpcpool/grpc_pool.go b/modules/rpc/grpcpool/grpc_pool.go index f62c0b5..ec08f4c 100644 --- a/modules/rpc/grpcpool/grpc_pool.go +++ b/modules/rpc/grpcpool/grpc_pool.go @@ -32,8 +32,8 @@ type GRPCPool struct { func (p *GRPCPool) Get(addr string) (*grpc.ClientConn, error) { p.RLock() - defer p.RUnlock() pool, ok := p.conns[addr] + p.RUnlock() if !ok { err := p.newCommonPool(addr) if err != nil { @@ -41,7 +41,9 @@ func (p *GRPCPool) Get(addr string) (*grpc.ClientConn, error) { } } + p.RLock() pool = p.conns[addr] + p.RUnlock() conn, err := pool.Get() if err != nil { return nil, err