定期刷新 golang 中的通道

我需要定期刷新频道的内容。 我用 len() 做到了这一点，我想知道是否有更好的方法来做到这一点。

http://play.golang.org/p/YzaI_2c_-F http://play.golang.org/p/YzaI_2c_-F

package main

import (
    "fmt"
    "math/rand"
    "time"
)

func main() {
    commch := make(chan int, 100)
    go fillchan(commch)
    drainchan(commch)
}

func fillchan(commch chan int) {
    for {
        select {
        case <-time.Tick(30 * time.Millisecond):
            commch <- rand.Int()
        }
    }
}

func drainchan(commch chan int) {
    for {
        chanlen := len(commch) // get number of entries in channel
        time.Sleep(1 * time.Second)
        for i := 0; i <= chanlen; i++ { //flush them based on chanlen
            fmt.Printf("chan len: %s num: %s\n", chanlen, <-commch)
        }
    }
}

EDIT 1:似乎这是更好的方法http://play.golang.org/p/4Kp8VwO4yl http://play.golang.org/p/4Kp8VwO4yl

package main

import (
    "fmt"
    "math/rand"
    "time"
)

func main() {
    commch := make(chan int, 1000)
    go fillchan(commch)
    for {
        select {
        case <-time.Tick(1000 * time.Millisecond):
            drainchan(commch)
        }
    }
}

func fillchan(commch chan int) {
    for {
        select {
        case <-time.Tick(300 * time.Millisecond):
            commch <- rand.Int()
        }
    }
}

func drainchan(commch chan int) {
    for {
        select {
        case e := <-commch:
            fmt.Printf("%s\n",e)
        default:
            return
        }
    }
}

EDIT 2:删除选择，防止内存泄漏随着时间的推移。勾选http://play.golang.org/p/WybAhRE3u4 http://play.golang.org/p/WybAhRE3u4

package main

import (
    "fmt"
    "math/rand"
    "time"
)

func main() {
    commch := make(chan int, 1000)
    go fillchan(commch)
    for _ = range time.Tick(1000 * time.Millisecond) {
        drainchan(commch)
    }
}

func fillchan(commch chan int) {
    for _ = range time.Tick(300 * time.Millisecond) {
        commch <- rand.Int()
    }
}

func drainchan(commch chan int) {
    for {
        select {
        case e := <-commch:
            fmt.Printf("%s\n", e)
        default:
            return
        }
    }
}

需要清除通道内容的情况并不常见。通道不提供此功能 - 但您可以创建一个以这种方式运行的 goroutine（...如果您really确实想要）。

通常，您会更多地考虑在一个通道上输入并在另一个通道上输出的 Goroutine；两个通道携带相同的数据类型。原则上，您可以通过这种方式对所有缓冲通道进行建模；对于它的客户端来说，goroutine 的行为就像一个普通的缓冲通道，因为它传递它接收到的内容。

将第三个通道添加到 goroutine 中，并结合select它和输入之间。这将允许您触发缓冲区的清空，而不会出现竞争条件。很简单。

现在有三个通道连接到 goroutine - 两个输入和一个输出。因此，当您设计将使用它的东西时，您可以推断刷新该数据的语义是什么。

我的脑海中浮现出一位亲戚。考虑一个具有一个输入和一个输出通道的 goroutine。它提供了一个固定大小的重写缓冲区，即即使输出通道被阻塞，也始终准备好从其输入通道读取。这还需要一个select使用默认情况，但不需要第三个通道。覆盖缓冲区有一个明确的用例：当通道和 goroutine 连接到循环中时，很可能会发生死锁。覆盖缓冲区作为死锁的一种候选解决方案很方便，因为某些数据在迟到时就没用了 - 例如，当应用程序太忙而无法响应鼠标事件时，您可以在 GUI 中丢弃这些事件。