测试目的,验证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("---主程序结束----")}
总结:
就是启动一个协程,每隔一定的时间,就去运行声明的匿名函数,直到接收到结束信号 就关闭这个协程
點(diǎn)擊查看更多內(nèi)容
為 TA 點(diǎn)贊
評(píng)論
評(píng)論
共同學(xué)習(xí),寫下你的評(píng)論
評(píng)論加載中...
作者其他優(yōu)質(zhì)文章
正在加載中
感謝您的支持,我會(huì)繼續(xù)努力的~
掃碼打賞,你說多少就多少
贊賞金額會(huì)直接到老師賬戶
支付方式
打開微信掃一掃,即可進(jìn)行掃碼打賞哦