草庐IT

go - 等待 sync.Waitgroup 延迟

coder 2023-06-28 原文

当从下面的 goroutine 在 channel 上发送时，我有以下代码进入死锁:

package main

import (
    "fmt"
    "sync"
)

func main() {
    for a := range getCh(10) {
        fmt.Println("Got:", a)
    }
}

func getCh(n int) <-chan int {
    var wg sync.WaitGroup
    ch := make(chan int)
    defer func() {
        fmt.Println("closing")
        wg.Wait()
        close(ch)
    }()
    wg.Add(1)
    go func() {
        defer wg.Done()
        for i := 0; i < n; i++ {
            ch <- i
        }
    }()
    wg.Add(1)
    go func() {
        defer wg.Done()
        for i := n; i < 0; i-- {
            ch <- i
        }
    }()

    return ch
}

我知道在defer中使用wg.Wait()是合法的。但是我一直没能在以 channel 作为返回值的函数中找到用途。

最佳答案

我认为您犯的错误是您认为 deferred 函数也将异步运行。但事实并非如此，因此 getCh() 将阻塞在其延迟部分，等待 WaitGroup。但是由于没有人从 channel 中读取，写入 channel 的 goroutines 无法返回，因此 WaitGroup 导致死锁。尝试这样的事情:

func getCh(n int) <-chan int {
    ch := make(chan int)
    go func() {
        var wg sync.WaitGroup
        wg.Add(1)
        go func(n int) {
            defer wg.Done()
            for i := 0; i < n; i++ {
                ch <- i
            }
        }(n)
        wg.Add(1)
        go func(n int) {
            defer wg.Done()
            for i := n; i > 0; i-- {
                ch <- i
            }
        }(n)
        wg.Wait()
        fmt.Println("closing")
        close(ch)
    }()

    return ch
}

关于go - 等待 sync.Waitgroup 延迟，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37943036/

Waitgroupsynccodesectionfuncgo

有关go - 等待 sync.Waitgroup 延迟的更多相关文章

  1. ruby-on-rails - 在 Ruby on Rails 中发送响应之前如何等待多个异步操作完成？ - 2

    在我做的一些网络开发中，我有多个操作开始，比如对外部API的GET请求，我希望它们同时开始，因为一个不依赖另一个的结果。我希望事情能够在后台运行。我找到了concurrent-rubylibrary这似乎运作良好。通过将其混合到您创建的类中，该类的方法具有在后台线程上运行的异步版本。这导致我编写如下代码，其中FirstAsyncWorker和SecondAsyncWorker是我编写的类，我在其中混合了Concurrent::Async模块，并编写了一个名为“work”的方法来发送HTTP请求:defindexop1_result=FirstAsyncWorker.new.async.

  2. ruby-on-rails - 在所有延迟的作业之前 Hook - 2

    是否可以在所有delayed_job任务之前运行一个方法？基本上，我们试图确保每个运行delayed_job的服务器都有我们代码的最新实例，所以我们想运行一个方法来在每个作业运行之前检查它。(我们已经有了“check”方法并在别处使用它。问题只是关于如何从delayed_job中调用它。) 最佳答案 现在有一种官方方法可以通过插件来做到这一点。这篇博文通过示例清楚地描述了如何执行此操作http://www.salsify.com/blog/delayed-jobs-callbacks-and-hooks-in-rails(本文中描述

  3. ruby - Watir ... sleep 和等待之间的区别 - 2

    有什么显着的区别吗sleep10和wait_until(10)他们似乎都在做同样的事情:WAITING10秒，然后继续下一步 最佳答案 sleep在指定时间内什么都不做。wait_untiltakesablock.它一直等到block评估为真或超时。如果没有给出block，它们的行为相同。 关于ruby-Watir...sleep和等待之间的区别，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/que

  4. ruby-on-rails - Textmate 'Go to symbol' 相当于 Vim - 2

    在Railcasts上，我注意到一个非常有趣的功能“转到符号”窗口。它像Command-T一样工作，但显示当前文件中可用的类和方法。如何在vim中获取它？ 最佳答案 尝试:helptags有各种程序和脚本可以生成标记文件。此外，标记文件格式非常简单，因此很容易将sed(1)或类似的脚本组合在一起，无论您使用何种语言，它们都可以生成标记文件。轻松获取标记文件(除了下载生成器之外)的关键在于格式化样式而不是实际解析语法。 关于ruby-on-rails-Textmate'Gotosymbol

  5. ruby - Heroku - 如何开始工作人员(延迟工作)？ - 2

    我有一些使用delayed_job的小程序。在我的本地主机上一切正常，但是当我将我的应用程序部署到Heroku并单击应该由delayed_job执行的链接时，没有任何反应，“任务”只是保存到表delayed_job中。Inthisarticleonherokublog写入时，执行delayed_job表中的任务，当运行此命令时rakejobs:work。但是我怎样才能运行这个命令呢？命令应该放在哪里？在代码中，还是从终端控制台？ 最佳答案 如果您正在运行Cedar堆栈，请从终端控制台运行以下命令:herokurunrakejobs:

  6. ruby-on-rails - 成功发送延迟作业电子邮件后更新用户表 - 2

    我是一个尝试使用delayed_job的NOOB。我想在使用延迟作业成功发送邮件后更新用户模型。发送邮件:UserMailer.delay.welcome_email(user)如果邮件发送成功，请执行以下操作:User.update_attributes(:emailed=>true)邮件发送成功后如何回调或触发？ 最佳答案 您需要创建一个Job对象而不是调用#delay帮助程序。您可以使用successHook来执行回调。classWelcomeEmailJob 关于ruby-on-

  7. ruby - 如何让 Selenium/Ruby 机器人在执行操作之前等待？ - 2

    我正在构建一个点击元素的Selenium/Ruby网络机器人。问题是，有时在机器人决定找不到元素之前没有足够的时间加载页面。让Selenium在执行操作之前等待的Ruby方法是什么？我更喜欢显式等待，但我也接受隐式等待。我尝试使用wait.until方法:require"selenium-webdriver"require"nokogiri"driver=Selenium::WebDriver.for:chromewait=Selenium::WebDriver::Wait.new(:timeout=>15)driver.navigate.to"http://google.com"dr

  8. ruby-on-rails - 启动同一作业的多个延迟作业进程 - 2

    我在运行多个工作器的设置中使用延迟作业。就我的问题而言，这并不重要，但假设我有10个worker(目前在开发模式下这样做)。我遇到的问题是两个不同的工作人员有时会开始处理同一个工作，调用我的工作对象的perform方法。据我所知，DelayedJob正在使用悲观锁定来防止这种情况发生，但有时它似乎仍然有足够的时间在第一个worker有时间实际锁定它之前锁定它。我只是想看看有没有其他人遇到过这个问题，或者是我的设置有问题。我正在使用Postrgres，这发生在我的开发机器和我托管它的Heroku上。我会尝试在我的工作中解决这个问题，但发生这种情况仍然有点问题。理想情况下，延迟作业永远不会

  9. ruby-on-rails - Rails 4.0.3 使用 asset_sync 生成不正确的 Assets 路径 - 2

    我以前多次使用asset_syncgem并取得了很大的成功，但是在Rails4.0.3项目中使用它似乎导致了问题。Assets被上传、散列并gzip到目标目录(我只是使用默认的“Assets”)，但是在暂存/生产环境中运行应用程序时，路径不正确。它们的形式是:S3_DOMAIN.com/stylesheets/application.css代替:S3_DOMAIN.com/assets/application-HASH.css有没有人遇到过这个问题？我发现扭转这种行为的唯一方法是将config.assets.compile设置为true，但这在生产环境中行不通。这里是相关的配置文件:#

  10. ruby - 如何等待 Selenium 中的页面重定向？ - 2

    我正在尝试执行一项相对简单的任务:WAITING页面重定向完成。刚刚看到another回答了有关该主题的问题，建议是等待后一页上的特定文本出现(如果我做对了)。如果是这样，等到window.location发生变化怎么样？好点吗？更差？不太适用？还有其他想法吗？只是好奇，如果需要，可以将此问题标记为社区wiki。谢谢! 最佳答案 是的，我在使用Selenium时遇到过很多次这个问题。我有两种方法解决这个问题。首先，您实际上可以更改隐式等待时间。例如给定这段代码:Actionsbuilder=newActions(driver);bu

随机推荐