您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
//测试wait.Until() 的用途
package main
import (
"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("---主程序结束----")
}
总结:
就是启动一个协程,每隔一定的时间,就去运行声明的匿名函数,直到接收到结束信号 就关闭这个协程
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。