如何在 Golang 中实现并发跟踪的最佳方法

一分耕耘，一分收获！既然都打开这篇《如何在 Golang 中实现并发跟踪的最佳方法》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

所以我一直在编写一个小玩具程序来像 Jenkins 一样运行简单的任务。该程序的一些功能是：

• 内存作业队列。
• 执行器（我可以使用 CLI 标志指定要从队列中同时运行多少个作业。）
• 可以通过 REST API 添加和取消作业（在队列中和运行时）。

我一直在遵循本教程，使用 goroutine 从通道中提取内容并进行处理。然而，我一直遇到这样的问题：如何实现取消某些已经在处理作业的 goroutine。例如：

我的队列中有 5 个作业和 2 个执行程序（执行程序 A 和执行程序 B）。两个执行器都从队列中取出一项作业并进行处理。但是，我想让执行程序 B 停止处理当前作业，并将下一个作业从队列中拉出。

似乎 goroutine 无法真正按照“goroutine A...B...C...”进行跟踪，并且似乎不是实现这种逻辑的最佳实践。话虽如此，有没有任何模式可以解决我的用例？

解决方案

在 goroutine 中取消处理的方法之一是使用可取消的上下文：context.withcancel。这为您提供了一个上下文和一个 cancel 函数，您可以使用它来通知 goroutine 它已被取消。 goroutine 应定期检查上下文，如果被取消则终止。

您可以使用上下文来跟踪 goroutine。对于您创建的每个 goroutine，您可以创建一个可取消的上下文，并将上下文和 cancel 函数保留在保存正在运行的任务的列表/映射中。那么你的 goroutine 将如下所示：

func executor(ctx context.context) {
  for {
     // do stuff
     select {
       case <-ctx.done():
           // terminate
       default:
     }
    // do more stuff
  }
}

您必须时不时地轮询上下文以查看它是否被取消。

然后你启动一个像这样的 goroutine：

go func() {
   ctx, cancel:=context.WithCancel(context.Background())
   defer cancel()
   // Store ctx and cancel in a map if you need to
   executor(ctx)
   // Remove stored context
}()

当你需要取消一个正在运行的goroutine时，调用它的cancel函数，它最终会终止。

今天关于《如何在 Golang 中实现并发跟踪的最佳方法》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！