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()`组合来实现多协程等待,如果某一协程未能合理处理错误,导致无法退出,此时需要引入超时机制。下面是一种超时处理方法。...
用渠道作为线程池,应对百万请求,这是 Marcio Castilho 优化的方法。核心代码:...
在go 里,多线程对共享数据的操作一般要使用Mutex 或 Channel 来加锁或隔离通信。下面是一个使用Mutex 和 Channel 比较的例子。...
启动一个 goroutine 等待进程,使用 select 等待 goroutine 完成的消息或超时处理。...
Pigo 是用纯 go 编写的基于像素强度比较算法的人脸检测库。...
编程时,我们通常需要编写“泛型”函数,其中确切的数据类型并不重要。例如,您可能想编写一个简单的函数来对数字进行求和。Go 直到最近才有这个概念,但最近才添加了它(从1.18版开始)。...
下面是 Golang slice 和 map 的查询性能比较代码...
Golang 有很多的模版引擎,自带的 `html/template` 也很好,大多数情况都能满足需求,只是有些逻辑、条件判断不好在模版里实现, `quicktemplate` 是个很好的选择。...
Socks5 代理较 `http/https` 代理有较好的性能,下面是借鉴某个著名开源软件的 local 实现的简单代理。...
gopsutil 是用go 实现python 写的psutil 的功能,并尝试在多平台上完整psutil 的函数。...