当前位置： > > > > golang goroutine 实践，功能还是通道？

golang goroutine 实践，功能还是通道？

来源：stackoverflow
2024-04-29 12:09:36
0浏览
收藏

哈喽！大家好，很高兴又见面了，我是米云的一名作者，今天由我给大家带来一篇《golang goroutine 实践，功能还是通道？》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

问题内容

不断地从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)
       }
    }

有没有什么鼓励的方法可以在不进行数据竞争的情况下实现目标，欢迎提出建议。 赞赏并感谢。

正确答案

尝试使用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)
}

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《golang goroutine 实践，功能还是通道？》文章吧，也可关注米云公众号了解相关技术文章。