[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() {
    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)
        }
    }
}