diff --git a/remoting/kubernetes/listener_test.go b/remoting/kubernetes/listener_test.go index 1f398485b2f16defddf44ce1a08a7ecfd9760dd1..5cfc051f5d18e8766fd9c62e609dce54c0de7722 100644 --- a/remoting/kubernetes/listener_test.go +++ b/remoting/kubernetes/listener_test.go @@ -18,7 +18,9 @@ package kubernetes import ( + "runtime" "testing" + "time" ) import ( @@ -51,6 +53,10 @@ var changedData = ` dubbo.service.com.ikurento.user.UserProvider.cluster=failover ` +func init(){ + runtime.GOMAXPROCS(1) +} + type mockDataListener struct { eventList []remoting.Event client *Client @@ -87,6 +93,7 @@ func TestListener(t *testing.T) { listener := NewEventListener(c) dataListener := &mockDataListener{client: c, changedData: changedData, rc: make(chan remoting.Event)} listener.ListenServiceEvent("/dubbo", dataListener) + time.Sleep(1e9) for _, tc := range tests {