Go 中如何延迟执行取消事件操作?

go 中如何延迟执行取消事件操作?

go 中在 select 中延迟执行取消事件

当需要在接收 ctx.done() 消息时延迟执行某个操作,但又不希望直接在 ctx.done() 内执行时,可以使用 select 来实现。

包代码:

import (
  "context"
  "fmt"
  "time"
)

func main() {
  // 设置上下文和 ticker
  ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
  defer cancel()
  ticker := time.NewTicker(1 * time.Second)

  // 开始 select
  shouldReturn := false
  for {
    select {
    case <-ctx.Done():
      shouldReturn = true
      fallthrough
    case <-ticker.C:
      // 执行代码
      fmt.Println("Ticker fired")

      if shouldReturn {
        return
      }
    }
  }
}

在这个示例中:

  • 创建一个带有超时的上下文 ctx。
  • 使用 newticker 创建一个 ticker。
  • select 中:

    • 监听 ctx.done() 通道,如果接收到消息,则将 shouldreturn 设置为 true 并使用 fallthrough 继续执行下一行。
    • 监听 ticker 通道,如果接收到消息,则执行代码并检查 shouldreturn 是否为 true。如果是,则退出循环。
  • 无限循环 select,直到收到 ctx.done() 消息或 ticker 触发。
  • 在收到 ctx.done() 消息后,我们允许 select 循环一次,以执行 ticker 代码,然后退出。

此方法允许您在收到取消信号后延迟执行操作,而无需将代码直接放在 ctx.done() 中。

以上就是Go 中如何延迟执行取消事件操作?的详细内容,更多请关注其它相关文章!