中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

怎么在golang中使用signal包的Notify方法

發布時間:2021-03-22 16:33:49 來源:億速云 閱讀:462 作者:Leah 欄目:開發技術

怎么在golang中使用signal包的Notify方法?很多新手對此不是很清楚,為了幫助大家解決這個難題,下面小編將為大家詳細講解,有這方面需求的人可以來學習下,希望你能有所收獲。

函數聲明為:

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

官方描述:

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

signal包不會為了向c發送信息而阻塞(就是說如果發送時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 循環中針對不同信號做不同的處理, for 循環為死循環。

補充:關于 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

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

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

  ...
  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 的作用。

看完上述內容是否對您有幫助呢?如果還想對相關知識有進一步的了解或閱讀更多相關文章,請關注億速云行業資訊頻道,感謝您對億速云的支持。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

海林市| 日喀则市| 昌都县| 淮安市| 漳浦县| 新郑市| 扬州市| 日喀则市| 都匀市| 来凤县| 台前县| 新晃| 绥棱县| 个旧市| 淄博市| 芒康县| 宁海县| 崇州市| 漾濞| 依安县| 大竹县| 隆林| 三都| 五原县| 宿松县| 安阳市| 大英县| 电白县| 仪陇县| 洛阳市| 宁波市| 徐水县| 海城市| 威宁| 苍溪县| 古田县| 河西区| 甘泉县| 登封市| 格尔木市| 石首市|