Golang Goroutine实践，功能还是渠道？

Question

不断从WebSocket接收JSON数据并在Goroutine中处理它们，不知道这种写作模式

    ws.onmessage {     //infinite receive message from websocket
        go func() {   //work find using this goroutine
            defer processJson(message)
        }()
        
        go processJson(message) //error and program will terminated
     }
    
    func processJson(msg string) {
        //code for  process json 
    
        insertDatabase(processedMsg)
    }
    
    func insertDatabase(processedMsg string) {
        //code insert to database
    }

在下面是否有鼓励（第一个Goroutine）工作正常，但是某个时候（一周）表明，代码中有数据竞赛并终止程序。

    go func() {  
        defer processJson(message)
    }()

几分钟后，第二个goroutine经常遇到错误，通常是“致命错误：运行时执行期间的意外信号”。

    go processJson(message)

从我的理解来看，两个goroutine都可以做到这一点，为什么第一个可以运行良好，第二个不能。我尝试使用频道，但与第一个Goroutine相比，没有太大的区别。

    msgChan := make(chan string, 1000)
    go processJson(msgChan)

    for {   //receive json from websocket, send to channel
        msgChan <- message
    }

    func JsonProcessor(msg chan string) {
       for {   //get data from channel, process in goroutine function
           msgModified := <-msg
           insertDatabase(msgModified)
       }
    }

如果没有数据竞赛，是否有任何鼓励的方法来实现目标，欢迎提出建议。 感谢，谢谢。

Answer 1

尝试使用sync.mutex避免使用数据赛车，

mutux := sync.Mutex{}
ws.onmessage {
  processJson(message)
}
func processJson(msg string) {
  mutux.Lock()
  // .........
  mutux.Unlock()
}

如果可以在没有数据赛车的情况下进行处理功能，请按以下方式进行多线程版本：

msgChan1 := make(chan string, 1000)
msgChan2 := make(chan string, 1000)

go func() {
  for m := range msgChan1 {
    // ...
  }
}()
go func() {
  for m := range msgChan2 {
    // ...
  }
}()

ws.onmessage {
  msgChan1 <- message
  msgChan2 <- message
}
ws.onclose {
  close(msgChan1)
  close(msgChan2)
}