保持 Go 通道中的值始终最新的方法是什么？

Go 语言中使用通道时，有时需要确保通道中始终只包含最新值。虽然通道本质上是先进先出（FIFO）缓冲区，但可以通过使用原子环缓冲区或互斥体来实现这一目的。原子环缓冲区会覆盖旧数据，而互斥体允许多个读取器同时访问数据，但只允许一个写入器写入数据，从而存储单个条目。这些方法可以确保通道中始终包含最新值，避免不必要的内存占用。

我从 go 开始，现在正在编写一个简单的程序，该程序从传感器读取数据并将其放入通道中以进行一些计算。我现在的工作方式如下：

package main

import (
    "fmt"
    "time"
    "strconv"
)

func get_sensor_data(c chan float64) {
    time.Sleep(1 * time.Second)  // wait a second before sensor data starts pooring in
    c <- 2.1  // Sensor data starts being generated
    c <- 2.2
    c <- 2.3
    c <- 2.4
    c <- 2.5
}

func main() {

    s := 1.1

    c := make(chan float64)
    go get_sensor_data(c)

    for {
        select {
        case s = <-c:
            fmt.Println("the next value of s from the channel: " + strconv.FormatFloat(s, 'f', 1, 64))
        default:
            // no new values in the channel
        }
        fmt.Println(s)

        time.Sleep(500 * time.Millisecond)  // Do heavy "work"
    }
}

这工作正常，但传感器会生成大量数据，而我始终只对最新数据感兴趣。然而，使用此设置时，它只会在每次循环时读出下一个项目，这意味着如果通道在某个时刻包含 20 个值，则仅在 10 秒后读出最新值。

有没有办法让一个通道每次总是只包含一个值，这样我总是只获取我感兴趣的数据，并且通道不会使用不必要的内存（虽然内存是最少的）我的担忧）？

解决方案

最好将通道视为队列 (fifo)。因此你不能真正跳过。然而，有一些库可以做这样的事情：https://github.com/cloudfoundry/go-diodes 是一个原子环缓冲区，它将覆盖旧数据。如果您愿意，可以设置较小的尺寸。

尽管如此，听起来您并不需要队列（或环形缓冲区）。你只需要一个互斥体：

type SensorData struct{
  mu sync.RWMutex
  last float64
}

func (d *SensorData) Store(data float64) {
 mu.Lock()
 defer mu.Unlock()

 d.last = data
}

func (d *SensorData) Get() float64 {
 mu.RLock()
 defer mu.RUnlock()

 return d.last
}

这使用了 rwmutex，这意味着许多东西可以同时从中读取，而只有一个东西可以写入。正如您所说，它将存储单个条目。

不。通道是 fifo 缓冲区，句号。这就是渠道的运作方式及其唯一目的。如果您只需要最新值，请考虑仅使用受互斥体保护的单个变量；每当有新数据到来时就写入它，并且每当您读取它时，您将始终读取最新的值。

今天关于《保持 Go 通道中的值始终最新的方法是什么？》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！