ConfigClient并发问题

[wcvb13]

nacos-sdk-go/clients/config_client/config_client.go

Line 265 in bcceb19

if remakeId < client.currentTaskCount {

nacos-sdk-go/clients/config_client/config_client.go

Line 374 in bcceb19

client.currentTaskCount = taskCount

这里client.currentTaskCount在测试时出现了data race

[wcvb13]

测试代码如下：

func main() {
	sc := []constant.ServerConfig{
		*constant.NewServerConfig("127.0.0.1", 8848),
	}

	cc := constant.ClientConfig{
		TimeoutMs:           5000,
		NotLoadCacheAtStart: true,
		LogDir:              "/tmp/nacos/log",
		CacheDir:            "/tmp/nacos/cache",
		LogLevel:            "debug",
	}

	client, err := clients.NewConfigClient(
		vo.NacosClientParam{
			ClientConfig:  &cc,
			ServerConfigs: sc,
		},
	)
	if err != nil {
		panic(err)
	}
	_, pErr := client.PublishConfig(vo.ConfigParam{DataId: "test.yaml", Group: "test", Content: "test: test"})
	if pErr != nil {
		fmt.Println(pErr)
		return
	}
	content := make(chan string, 100)
	e := client.ListenConfig(vo.ConfigParam{
		DataId: "test.yaml",
		Group:  "test",
		OnChange: func(_, group, dataId, data string) {
			if dataId == "test.yaml" && group == "test" {
				fmt.Println("input data: " + data)
				content <- data
			}
		},
	})
	if e != nil {
		fmt.Println(e)
		return
	}
	_, pErr = client.PublishConfig(vo.ConfigParam{DataId: "test.yaml", Group: "test", Content: "test: test"})
	if pErr != nil {
		fmt.Println(pErr)
		return
	}
	err = client.CancelListenConfig(vo.ConfigParam{DataId: "test.yaml", Group: "test"})
	if err != nil {
		fmt.Println(err)
		return
	}
}