executor.go

// set a logger to show who is blocking
concurrent.InfoLogger = log.New(os.Stdout, "", 0)
executor := concurrent.NewUnboundedExecutor()
executor.Go(func(ctx context.Context) {
  everyMillisecond := time.NewTicker(time.Millisecond)
  for {
    select {
    case <-ctx.Done():
      // info log will be printed while we wait
      time.Sleep(time.Second)
      fmt.Println("goroutine exited")
      return
    case <-everyMillisecond.C:
      // do something
    }
  }
})
time.Sleep(time.Second)
executor.StopAndWaitForever()
fmt.Println("executor stopped")