[Go] gocron源码阅读-groutine与channel应用到信号捕获
2023-02-18 15:41:50 时间
直接使用go 函数名()可以开启一个grountine,channel可以接收信息并且如果没有数据时会阻塞住
channel对应的是底层数据结构的引用,复制channel和函数传参都是拷贝的引用
make的时候第二个参数是1,就表示是有缓存的channel
无缓存的channel也叫同步channel
c = make(chan interface{}) //开启groutine go mySig() //主grountine不能断 for { time.Sleep(time.Second) c <- "taoshihan" } func mySig() { for { str := <-c fmt.Println(str) } }
信号处理使用channel通信
func catchSignal() { c := make(chan os.Signal, 1) signal.Notify(c, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM) for { s := <-c logger.Info("收到信号 -- ", s) switch s { case syscall.SIGHUP: logger.Info("收到终端断开信号, 忽略") case syscall.SIGINT, syscall.SIGTERM: shutdown() } } }
完整代码:
package main import ( "fmt" "os" "os/signal" "syscall" "time" ) var c chan interface{} func main() { go catchSignal() c = make(chan interface{}) //开启groutine go mySig() //主grountine不能断 for { time.Sleep(time.Second) c <- "taoshihan" } } func mySig() { for { str := <-c fmt.Println(str) } } func catchSignal() { d := make(chan os.Signal, 1) signal.Notify(d, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM) for { s := <-d fmt.Println("收到信号 -- ", s) switch s { case syscall.SIGHUP: fmt.Println("收到终端断开信号, 忽略") case syscall.SIGINT, syscall.SIGTERM: //这里可以做一些退出动作 fmt.Println("关闭") os.Exit(0) } } }
相关文章
- 【Linux】Linux - CenterOs 7.9中搭建Nacos 2.x
- 云原生下基于K8S声明式GitOps持续部署工具ArgoCD实战-上
- 分布式NoSQL数据库MongoDB初体验-v5.0.5
- Linux系列之链接
- Linux系列之压缩命令
- Linux系列之重定向操作
- Linux系列之比较命令
- Linux系列之管理用户环境变量
- Linux系列之进程管理
- Linux系列之文件和目录权限
- Linux系列之添加和删除软件命令
- Linux系列之文本操作命令
- Linux系列之查找命令
- 基础架构之Gitlab Runner
- 基础架构之GitLab
- 基础架构之Mongo
- 为mongodb添加账号
- MongoDB(online) 优化
- Git使用详细教程(二)
- Git使用详细教程(一)