subscriber.go

func main() {
  // シグナルを受け取るまで待ち受けるためのChannel
  doneCh := make(chan struct{}
                 
  // シグナルを受け取るChannel
  signalCh := make(chan os.Signal, 1)
  signal.Notify(signalCh, os.Interrupt)
  
  // メッセージを受け取る処理をgoroutineで動かす
  go receive(signalCh, doneCh)
  
  // シグナルを受け取るまで待ち受ける
  <-doneCh
}

func receive(signalCh chan os.Signal, doneCh chan struct{}) {
  for {
    select {
    // case msg := <-hoge(): メッセージを受け取って何か処理を行なう
    case <-signalCh:
      doneCh <- struct{}{}
    }
  }
}