为了账号安全,请及时绑定邮箱和手机立即绑定

填充一个缓冲的 chan 直到填满或一段时间过去

填充一个缓冲的 chan 直到填满或一段时间过去

Go
喵喔喔 2021-11-08 16:13:53
我有一个chan string缓冲的,我一直用随机字符串填充它,直到一段时间。持续时间过去或直到它变满。我的问题是,考虑到它是一次性任务还是有更方便的方法,我应该使用自动收报机吗?这是我目前的做法package mainimport (    "fmt"    "time")func main() {    res := fillChan(time.Duration(1*time.Nanosecond), 100000)    fmt.Println(len(res))}func fillChan(maxDuration time.Duration, chanSize int) chan string {    c := make(chan string, chanSize)    ticker := time.NewTicker(maxDuration)    for {        select {        case <-ticker.C:            ticker.Stop()            return c        case c <- "Random message":        default:            return c        }    }}
查看完整描述

1 回答

?
白衣非少年

TA贡献1155条经验 获得超0个赞

我不是围棋专家(事实上,我从未使用过它),但文档建议Timer,或After用于单个事件。


select {

case <-time.After(1*time.Nanosecond):

    return c

case c <- "Random message":

default:

    return c

}


查看完整回答
反对 回复 2021-11-08
  • 1 回答
  • 0 关注
  • 161 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信