使用 Go 通道进行数据传输

在 Go 语言中，通道是一种用于协程之间数据传输的机制。本文展示了如何使用通道在协程中不断生成数据，并通过网络套接字发送。作者发现，代码卡在向通道发送数据时，阻止了主函数的继续运行。通过修改代码，关闭通道并从通道持续读取数据，解决了该问题。改进后的代码可以无限期地在后台运行，并在数据到达时打印输出。

我正在尝试构建一个向其传递通道的函数，当在 go 例程中运行时，它将不断向通道发布更新（在本例中为 sin 值）。当数据发送到通道时，我想通过网络套接字发送它。

func sineWave(value chan float64) {
    var div float64
    sinMult := 6.2839
    i := 0
    log.Println("started")

    for {
        div = (float64(i+1) / sinMult)
        log.Println(math.Sin(div))
        time.Sleep(100 * time.Millisecond)
        value <- math.Sin(div)
        // log.Println()

        i++
        if i == 45 {
            i = 0
        }
    }
    // log.Println(math.Sin(div * math.Pi))
}

它似乎卡在 value <- main.sin(div) 上，阻止 main() 的其余部分运行。如何让 sinewave 在后台无限期运行并在另一个函数到达时打印其输出？

解决方案

这段代码有几个错误，

• 值 chan 永远不会耗尽，因此任何写入都会阻塞
• 值 chan 永远不会关闭，因此任何消耗都将是无限的

通道必须始终被清空，通道必须在某个时刻关闭。

另外，请发布可重现的示例，否则很难诊断问题。

这是 op 代码的稍微修改但有效的版本。

package main

import (
    "fmt"
    "math"
    "time"
)

func sineWave(value chan float64) {
    defer close(value) // A channel must always be closed by the writer.
    var div float64
    sinMult := 6.2839
    i := 0
    fmt.Println("started")

    for {
        div = (float64(i+1) / sinMult)

        time.Sleep(100 * time.Millisecond)
        value <- math.Sin(div)

        i++
        if i == 4 {
            // i = 0 // commented in order to quit the loop, thus close the channel, thus end the main for loop
            break
        }
    }

}

func main() {
    value := make(chan float64)
    go sineWave(value) // start writing the values in a different routine
    // drain the channel, it will end the loop whe nthe channel is closed
    for v := range value {
        fmt.Println(v)
    }
}

终于介绍完啦！小伙伴们，这篇关于《使用 Go 通道进行数据传输》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！