濮阳杆衣贸易有限公司

主頁 > 知識庫 > golang 中signal包的Notify用法說明

golang 中signal包的Notify用法說明

熱門標簽:地圖標注免費定制店 不封卡外呼系統(tǒng) 重慶慶云企業(yè)400電話到哪申請 鄭州智能語音電銷機器人價格 寧波語音外呼系統(tǒng)公司 宿遷便宜外呼系統(tǒng)代理商 仙桃400電話辦理 上海極信防封電銷卡價格 湛江crm外呼系統(tǒng)排名

函數(shù)聲明為:

func Notify(c chan- os.Signal, sig ...os.Signal)

官方描述:

Notify函數(shù)讓signal包將輸入信號轉發(fā)到c。如果沒有列出要傳遞的信號,會將所有輸入信號傳遞到c;否則只傳遞列出的輸入信號。

signal包不會為了向c發(fā)送信息而阻塞(就是說如果發(fā)送時c阻塞了,signal包會直接放棄):調用者應該保證c有足夠的緩存空間可以跟上期望的信號頻率。對使用單一信號用于通知的通道,緩存為1就足夠了。

示例代碼:

ch := make(chan os.Signal, 1)
  signal.Notify(ch, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGSTOP, syscall.SIGUSR1)
  for {
    s := -ch
    switch s {
    case syscall.SIGQUIT:
      log.Infof("SIGSTOP")
      return
    case syscall.SIGSTOP:
      log.Infof("SIGSTOP")
      return
    case syscall.SIGHUP:
      log.Infof("SIGHUP")
      return
    case syscall.SIGKILL:
      log.Infof("SIGKILL")
      return
    case syscall.SIGUSR1:
      log.Infof("SIGUSR1")
      return
    default:
      log.Infof("default")
      return
    }
  }

以上代碼告訴 signal ,將對應的信號通知 ch,然后在 for 循環(huán)中針對不同信號做不同的處理, for 循環(huán)為死循環(huán)。

補充:關于 signal.Notify 使用帶緩存的 channel

package main
import (
  "fmt"
  "os"
  "os/signal"
)
func main() {
  // Set up channel on which to send signal notifications.
  // We must use a buffered channel or risk missing the signal
  // if we're not ready to receive when the signal is sent.
  c := make(chan os.Signal, 1)
  signal.Notify(c, os.Interrupt)
  // Block until a signal is received.
  s := -c
  fmt.Println("Got signal:", s)
}

上面一段代碼是 signal.Notify 的事例代碼,注釋說:

我們得使用帶緩沖 channel

否則,發(fā)送信號時我們還沒有準備好接收,就有丟失信號的風險

我一直沒理解這段注釋,于是翻看源碼 $GOROOT/src/os/signal/signal.go,有這樣一段代碼,并注釋有“發(fā)送但不阻塞”。這里應該就是“有可能丟失信號”的原因了吧。

  ...
  for c, h := range handlers.m {
    if h.want(n) {
      // send but do not block for it
      select {
      case c - sig:
      default:
      }
    }
  }
  ...

于是,我寫了一段代碼進行測試:

package main
import (
  "log"
  "os"
  "os/signal"
  "time"
)
func main() {
  c := make(chan os.Signal)
  signal.Notify(c, os.Interrupt)
  time.Sleep(time.Second * 5) // 假裝 5 秒沒準備好接收
  s := -c
  log.Println(s)
}

在使用不帶緩存的 channel 時,5 秒的 sleep 期間無論按多少個 control + c,sleep 結束都不會打印,也不會退出程序;

在使用帶緩存的 channel 時,只要接收到一個 SIGINT ,在 sleep 結束后也就是準備好接收,便會打印并退出程序。

這就是 signal.Notify 使用帶緩存 channel 的作用。

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • golang strings包的Replace的使用說明
  • golang 中strings包的Replace的使用說明
  • Golang Printf,Sprintf,Fprintf 格式化詳解
  • 完美解決go Fscanf 在讀取文件時出現(xiàn)的問題
  • Golang 并發(fā)以及通道的使用方式
  • golang 如何替換掉字符串里面的換行符\n
  • golang監(jiān)聽文件變化的實例

標簽:青海 海南 電子產品 物業(yè)服務 安康 儋州 遼寧 西雙版納

巨人網絡通訊聲明:本文標題《golang 中signal包的Notify用法說明》,本文關鍵詞  golang,中,signal,包的,Notify,;如發(fā)現(xiàn)本文內容存在版權問題,煩請?zhí)峁┫嚓P信息告之我們,我們將及時溝通與處理。本站內容系統(tǒng)采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《golang 中signal包的Notify用法說明》相關的同類信息!
  • 本頁收集關于golang 中signal包的Notify用法說明的相關信息資訊供網民參考!
  • 推薦文章
    横峰县| 吴桥县| 宝应县| 昌图县| 兰州市| 凤凰县| 安康市| 彝良县| 得荣县| 夏河县| 云阳县| 德安县| 安泽县| 乾安县| 老河口市| 宁陵县| 高邮市| 托里县| 慈溪市| 玉溪市| 丽水市| 上杭县| 东阳市| 东方市| 阿拉善左旗| 望谟县| 新源县| 收藏| 贵定县| 大安市| 民和| 开江县| 方山县| 武强县| 清丰县| 南华县| 木兰县| 兴化市| 含山县| 沁水县| 临桂县|