如何有效限制Go例程并发？

限制并发 Go 例程

在您的代码中，您尝试限制并发 goroutine 的数量。然而，当前的实现并没有按预期工作。这是另一种方法：

解决方案：

不要为每个 URL 创建一个 goroutine，而是创建固定数量的工作线程来处理来自共享通道的 URL。下面是修改后的代码：

<code class="go">parallel := flag.Int("parallel", 10, "max parallel requests allowed")
flag.Parse()

// Workers get URLs from this channel
urls := make(chan string) 

// Feed the workers with URLs
go func() {
    for _, u := range flag.Args() {
        urls <p><strong>说明：</strong></p>
<ul>
<li>创建一个缓冲通道 url，它将向工作人员提供 URL。</li>
<li>一个单独的 goroutine 负责向 urls 通道提供提供的 URL。</li>
<li>创建了所需数量的工作线程。每个工作线程从 urls 通道中提取 URL 并串行处理它们。</li>
<li>当所有工作线程完成处理时，goroutine 关闭结果通道以表明所有结果已被检索。</li>
</ul>
<p>这方法确保在任何给定时间最多有并行 goroutine 处于活动状态，从而根据需要限制并发性。</p></code>

以上是如何有效限制Go例程并发？的详细内容。更多信息请关注PHP中文网其他相关文章！