微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

[Go] gocron源码阅读-groutine与channel应用到信号捕获

直接使用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 举报,一经查实,本站将立刻删除。

相关推荐