對于以下代碼：閱讀器.gofunc (r *Reader) ReadData(objCh chan *data.InputEntry, stopCh chan struct{}) { var object data.InputEntry go func() { for { .... jsonErr := json.Unmarshal(byteBuffer[:n], &object) // Line 55 ... objCh <- &object } }()}作家.gofunc (w *Processor) ProcessData(objectCh chan *data.InputEntry, stopCh chan struct{}) { go func() { for { object, wd := <-objectCh ... w.Log.Printf("Received object: %v\n", object) // Line 83 } }()}以下是錯誤：WARNING: DATA RACEWrite at 0x00c000138000 by goroutine 7: reflect.Value.SetString() /usr/local/go/src/reflect/value.go:1712 +0xb3 encoding/json.(*decodeState).literalStore() /usr/local/go/src/encoding/json/decode.go:972 +0x3179 encoding/json.(*decodeState).value() /usr/local/go/src/encoding/json/decode.go:401 +0x2dc encoding/json.(*decodeState).object() /usr/local/go/src/encoding/json/decode.go:782 +0x225e encoding/json.(*decodeState).value() /usr/local/go/src/encoding/json/decode.go:387 +0xaf encoding/json.(*decodeState).unmarshal() /usr/local/go/src/encoding/json/decode.go:180 +0x27a encoding/json.Unmarshal() /usr/local/go/src/encoding/json/decode.go:107 +0x1de github.com/myhub/code/reader.(*Reader).ReadData.func1() /home/../code/src/github.com/myhub/code/reader/reader.go:55 +0x385Previous read at 0x00c000138000 by goroutine 8: reflect.typedmemmove() /usr/local/go/src/runtime/mbarrier.go:177 +0x0 reflect.packEface() /usr/local/go/src/reflect/value.go:119 +0x126 reflect.valueInterface() /usr/local/go/src/reflect/value.go:1023 +0x1b9 reflect.Value.Interface() /usr/local/go/src/reflect/value.go:993 +0x3c27 fmt.(*pp).printValue()reader.go第 55( ) 行和第 83( writer.go)行之間的數據競爭如何解決此錯誤？
1 回答
倚天杖
TA貢獻1828條經驗 獲得超3個贊
您將一個變量的地址從一個 goroutine 發送到另一個，然后從兩個 goroutine 讀取/寫入該變量，即object.
解決方案是作為值傳遞object，或者為閱讀器中的每次迭代重新定義對象。在閱讀器的當前實現中，object定義在啟動 goroutine 的函數中。似乎沒有理由這樣做。只需object在 goroutine 的 for 循環中聲明即可。
go func() {
for {
....
var object data.InputData
jsonErr := json.Unmarshal(byteBuffer[:n], &object)
...
objCh <- &object
}
}()
或者：
go func() {
for {
....
jsonErr := json.Unmarshal(byteBuffer[:n], &object)
...
objCh <- object
}
}()
- 1 回答
- 0 關注
- 134 瀏覽
添加回答
舉報
0/150
提交
取消