测试目的，验证wait.Until的用法
//测试wait.Until() 的用途package mainimport ( "fmt" "k8s.io/apimachinery/pkg/util/wait" "time")type stop struct {}func main() { stopCh := make(chan struct{}) //初始化一个计数器 i := 0 go wait.Until(func() { fmt.Printf("----%d----n", i) i++ }, time.Second, stopCh) time.Sleep(time.Second * 10) stopCh <- stop{} // 下面的形式，也是可以的 //stopCh < struct { //}{} fmt.Println("---上面的go routines 结束----") // 主程序，再休息3秒钟，再结束 time.Sleep(time.Second * 3) fmt.Println("---主程序结束----")}
总结：
就是启动一个协程，每隔一定的时间，就去运行声明的匿名函数，直到接收到结束信号 就关闭这个协程
来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/2236/viewspace-2817733/ ，如需转载，请注明出处，否则将追究法律责任。
请登录后发表评论
登录
全部评论
