直接使用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() { { str := <-c fmt.Println(str) } }
信号处理使用channel通信
func catchSignal() { c := make(chan os.Signal,1) signal.Notify(c,syscall.SIGHUP,syscall.SIGINT,syscall.SIGTERM) { s := <-c logger.Info(收到信号 -- ,s) switch s { case syscall.SIGHUP: logger.Info(收到终端断开信号,忽略) syscall.SIGINT,syscall.SIGTERM: shutdown() } } }
完整代码:
package main import ( fmt" osos/signalsyscalltime ) var c chan interface{} func main() { go catchSignal() c = } } func mySig() { .Println(str) } } func catchSignal() { d := ) signal.Notify(d,1)">d fmt.Println( syscall.SIGHUP: 这里可以做一些退出动作 关闭) os.Exit(0) } } }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。