tianping526 commented on issue #1014: URL: https://github.com/apache/rocketmq-clients/issues/1014#issuecomment-2964725375
A data race seems to have been resolved in this issue https://github.com/apache/rocketmq-clients/issues/811 ``` WARNING: DATA RACE Read at 0x00c000143438 by goroutine 18: github.com/apache/rocketmq-clients/golang/v5.(*defaultProducer).takeMessageQueues() /go/pkg/mod/github.com/apache/rocketmq-clients/golang/[email protected]/producer.go:82 +0xb1 github.com/apache/rocketmq-clients/golang/v5.(*defaultProducer).send0() /go/pkg/mod/github.com/apache/rocketmq-clients/golang/[email protected]/producer.go:329 +0xa1b github.com/apache/rocketmq-clients/golang/v5.(*defaultProducer).getPublishingTopicRouteResult() /go/pkg/mod/github.com/apache/rocketmq-clients/golang/[email protected]/producer.go:92 +0xfc github.com/apache/rocketmq-clients/golang/v5.(*defaultProducer).send0() ... Previous write at 0x00c000143438 by goroutine 180: sync/atomic.StoreInt32() /usr/local/go/src/runtime/race_amd64.s:231 +0xb sync/atomic.StoreUint32() <autogenerated>:1 +0x14 internal/sync.(*HashTrieMap[go.shape.interface {},go.shape.interface {}]).initSlow() /usr/local/go/src/internal/sync/hashtriemap.go:55 +0x166 internal/sync.(*HashTrieMap[go.shape.interface {},go.shape.interface {}]).init() /usr/local/go/src/internal/sync/hashtriemap.go:32 +0x46 internal/sync.(*HashTrieMap[go.shape.interface {},go.shape.interface {}]).LoadAndDelete() /usr/local/go/src/internal/sync/hashtriemap.go:310 +0x64 sync.(*Map).LoadAndDelete() /usr/local/go/src/sync/hashtriemap.go:73 +0x44 github.com/apache/rocketmq-clients/golang/v5.(*defaultClient).doHeartbeat() ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
