Go 语言的 channel 本身是不支持 timeout 的,所以一般实现 channel 的读写超时都采用 select

如下:
Go: select channel
1
2
3
4 |
select {
case <-c:
case <-time.After(time.Second):
}
|
golang select机制
检查每个case语句
- 如果有任意一个chan是send or recv read,那么就执行该block
- 如果多个case是ready的,那么随机找1个并执行该block
- 如果都没有ready,那么就block and wait
- 如果有default block,而且其他的case都没有ready,就执行该default bloc
正确的 channel timeout 也许应该这么做 :
Go: channel timeout
1
2
3
4
5
6
7
8 |
to := time.NewTimer(time.Second)
for {
to.Reset(time.Second)
select {
case <-c:
case <-to.C:
}
}
|
本文网址: https://golangnote.com/topic/8.html 转摘请注明来源
Related articles
sync.WaitGroup 使用 `Add(1)`、`Done()`、`Wait()`组合来实现多协程等待,如果某一协程未能合理处理错误,导致无法退出,此时需要引入超时机制。下面是一种超时处理方法。...
启动一个 goroutine 等待进程,使用 select 等待 goroutine 完成的消息或超时处理。...
在go 里,多线程对共享数据的操作一般要使用Mutex 或 Channel 来加锁或隔离通信。下面是一个使用Mutex 和 Channel 比较的例子。...
用渠道作为线程池,应对百万请求,这是 Marcio Castilho 优化的方法。核心代码:...
一个 web 应用通常是跑在一个前端代理,如 Nginx 后,这样可以方便的在同一个服务器部署多个应用。这里说的独立部署是指让 go web 程序直接暴露在外面,独占 443、80 端口(俗称裸跑)。这样做除了性能有些提高外,更重要的是部署方便。...
golang 获取用户真实访问ip 地址...
给定一个不没有重复字符的字符串,如 `[0-9,a-z]`,把一个 10 进制数字转为,该字符集的字符串。应用场合如汽车牌、顺序计数。...
编程时,我们通常需要编写“泛型”函数,其中确切的数据类型并不重要。例如,您可能想编写一个简单的函数来对数字进行求和。Go 直到最近才有这个概念,但最近才添加了它(从1.18版开始)。...
有时候需要得出字符串中包含某个字符的个数,或者是包含某些字符集的个数,这里使用 `strings` 和 `regexp` 库实现。...
telegram 的机器人接口很开放,使用简单,100%开放无限制,相对微信服务号、公众号好很多。用来做一些小应用也很方便。下面是使用golang sdk 开发telegram 机器人的经验。...