Golang中的time.After的使用理解

关于在goroutine中使用time.After的理解, 新手在学习过程中的"此时此刻"的理解,错误还请指正。

先线上代码:

package main
import (
	"fmt"
	"time"
)
func main() {
	//closeChannel()
	c := make(chan int)
	timeout := time.After(time.Second * 2) //
	t1 := time.NewTimer(time.Second * 3) // 效果相同 只执行一次
	var i int
	go func() {
		for {
			select {
			case <-c:
				fmt.Println("channel sign")
				return
			case <-t1.C: // 代码段2
				fmt.Println("3s定时任务")
			case <-timeout: // 代码段1
				i++
				fmt.Println(i, "2s定时输出")
			case <-time.After(time.Second * 4): // 代码段3
				fmt.Println("4s timeout。。。。") 
			default: // 代码段4
				fmt.Println("default")
				time.Sleep(time.Second * 1)
			}
		}
	}()
	time.Sleep(time.Second * 6)
	close(c)
	time.Sleep(time.Second * 2)
	fmt.Println("main退出")
}

主要有以上4点是我们平时遇到的。

首先遇到的问题是:

如上的代码情况下, 代码段3处的case 永远不执行, 无论main进程执行多久。这是为什么呢?

首先我们分析为啥不执行代码段3, 而是程序一直执行的是default. 由此我们判断:

case <- time.After(time.Second) :

是本次监听动作的超时时间, 意思就说,只有在本次select 操作中会有效, 再次select 又会重新开始计时(从当前时间+4秒后), 但是有default ,那case 超时操作,肯定执行不到了。

那么问题就简单了我们预先定义了计时操作:

case <- timeout:

在goroutine开始前, 我们记录了时间,在此时间3s之后进行操作。相当于定时任务, 并且只执行一次。 代码段1和代码段2 实现的结果都相同

针对以上问题解决后,我写了一个小案例:

package main
import (
	"fmt"
	"time"
)
//发送者
func sender(c chan int) {
	for i := 0; i < 100; i++ {
		c <- i
		if i >= 5 {
			time.Sleep(time.Second * 7)
		} else {
			time.Sleep(time.Second)
		}
	}
}
func main() {
	c := make(chan int)
	go sender(c)
	timeout := time.After(time.Second * 3)
	for {
		select {
		case d := <-c:
			fmt.Println(d)
		case <-timeout:
			fmt.Println("这是定时操作任务 >>>>>")
		case dd := <-time.After(time.Second * 3):
			fmt.Println(dd, "这是超时*****")
		}
		fmt.Println("for end")
	}
}

执行结果:

要注意的是,虽然执行到i == 6时, 堵塞了,并且执行了超时操作, 但是下次select 依旧去除的是6

因为通道中已经发送了6,如果未取出,程序堵塞。

本文来自:开源中国博客

感谢作者:90design

查看原文:Golang中的time.After的使用理解

• 编辑
• 预览