From 0713fc1862d4eae0fc73518d32b9f169f1de279c Mon Sep 17 00:00:00 2001
From: pantianying <601666418@qq.com>
Date: Fri, 14 Feb 2020 20:22:30 +0800
Subject: [PATCH] add Rlock for dubbo Invoker
---
protocol/dubbo/dubbo_invoker.go | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/protocol/dubbo/dubbo_invoker.go b/protocol/dubbo/dubbo_invoker.go
index 67d1d1e7f..a843f437d 100644
--- a/protocol/dubbo/dubbo_invoker.go
+++ b/protocol/dubbo/dubbo_invoker.go
@@ -47,6 +47,7 @@ var (
// DubboInvoker ...
type DubboInvoker struct {
+ sync.RWMutex
protocol.BaseInvoker
client *Client
quitOnce sync.Once
@@ -62,6 +63,8 @@ func NewDubboInvoker(url common.URL, client *Client) *DubboInvoker {
// Invoke ...
func (di *DubboInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result {
+ di.RLock()
+ defer di.RUnlock()
var (
err error
result protocol.RPCResult
@@ -109,11 +112,15 @@ func (di *DubboInvoker) Invoke(ctx context.Context, invocation protocol.Invocati
// Destroy ...
func (di *DubboInvoker) Destroy() {
+ di.Lock()
+ defer di.Unlock()
+
di.quitOnce.Do(func() {
di.BaseInvoker.Destroy()
if di.client != nil {
di.client.Close()
+ di.client = nil
}
})
}
--
GitLab