GoLang 示例程序实现并发

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《GoLang 示例程序实现并发》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我正在构建一个 API，它可以对获取外部网站的请求进行排队，然后通过与该 API 交互来执行一些工作。我正在尝试找出如何避免重复 同时执行 go 例程。

也就是说，假设有一个针对 http://www.example.com 的请求，启动例程来处理该 URL，该例程可能会持续几分钟甚至几小时。发生这种情况时，可能会出现任意数量的其他请求。如果新请求尚未得到处理，他们应该继续执行自己的例程来完成。

但是，如果传入 example.com 的另一个请求，我希望请求传入的线程阻塞，直到前一个 example.com 请求完成，然后它可以继续（如果第一个任务成功，则可以重复）这将是一个快速的 GET 确认，如果失败，再试一次就可以了）。

我发现的所有代码示例都使用通道或等待组，但这些概念似乎都只阻塞一个线程。也就是说，第一个 example.com 线程正在等待某个通道返回值，但我不能让 example.com 请求 #2 在同一通道上等待，因为结果只能从通道读取一次。

如果有什么区别的话，我正在构建一个包含 5 个工作人员的工作人员池，如果另一个工作人员已经在处理 example.com 请求，则不会分配一个工作人员。

我还考虑过使用缓冲区来跟踪工作人员当前正在处理的 URL，但我不确定如何阻止等待从缓冲区中删除 URL。我看到一个使用无限 for 循环和当 URL 不再存在于缓冲区中时使用中断的示例，但这似乎是不必要的 CPU 滥用（无限期地在缓冲区上执行 for range 寻找 URL 不再存在并然后中断）。

如何对这些请求进行排队？

编辑：我正在寻找的解决方案是信号通道。感谢 Burak Serdar 向我指出这一点。如果其他人需要此信息，请搜索“信号通道”，您会找到大量信息。

正确答案

如果你想根据 url 来阻止 goroutine，你可以实现如下方案：

首先，保留所有正在处理的 url 的映射：

var urls = make(map[string]chan struct{})
var urllock = sync.mutex{}

以下 addurl 会将正在处理的 url 添加到 urls 地图（如果不存在），并将返回一个通道以通知该任务完成。如果 url 已经在地图中，它将返回 false 并带有等待通道。

func addurl(u string) (bool,chan struct{}) {
   urllock.lock()
   defer urllock.unlock()
   ret, exists:=urls[u]
   if exists {
     return true,ret
   }
   ret=make(chan struct{})
   urls[u]=ret
   return false,ret
}

当您获得要使用的新网址时，请尝试将其放在地图上。如果可以的话，那就努力吧：

workonurl, ch:=addurl(newurl)
if workonurl {
    go func() {
        defer removeurl(newurl)
        // work on url
    }()
} else {
  <-ch // wait for the goroutine to finish
  // then, you can try rescheduling the same url, or do something else
}

使用 removeurl，从地图中删除 url，并关闭通道，以便任何等待完成的 goroutine 可以继续：

func removeURL(u string) {
   urllock.Lock()
   defer urllock.Unlock()
   ret:=urls[u]
   delete(urls,u)
   close(ret)
}

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~