golang学习的点点滴滴:并发超时处理

golang并没有在语言层次上提供超时操作,但可以通过一些小技巧实现超时。

原理:

并发一个函数,等待1s后向timeout写入数据,在select中如果1s之内有数据向其他channel写入则会顺利执行,如果没有,这是timeout写入了数据,则我们知道超时了。

package main 
import "fmt"
import "time"

func main() {
	ch := make(chan int, 1)
	timeout := make(chan bool, 1)

	// 并发执行一个函数,等待1s后向timeout写入true
	go func() {
		time.Sleep(1000)
		timeout <- true
	}()


	// 这里会等待ch或timeout读出数据
	// 因为一直没有向ch写入数据
	// 在1s后向timeout写入了数据
	// 所以执行了timeout的case
	// 利用这个技巧可以实现超时操作
	select {
		case <- ch :
			fmt.Println("read from ch")
		case <- timeout :
			fmt.Println("time out...")
	}
}


本文来自:开源中国博客

感谢作者:亓斌哥哥

查看原文:golang学习的点点滴滴:并发超时处理

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。