登录
首页 >  Golang >  Go问答

为何我无法前进?

来源:stackoverflow

时间:2024-03-21 19:36:36 129浏览 收藏

**为何我无法前进?** 在尝试同时运行三个函数时,遇到僵局。由于第二个和第三个函数依赖于第一个函数的值,因此只能在第一个函数中的某个点之后运行它们。使用通道时,代码会阻塞,因为第二个和第三个函数正在等待接收第一个函数发送的值。本文将探讨解决方案,其中包括在检查通道值后选择性地执行函数,以及在第一个函数发送特定值后同时运行所有函数。

问题内容

我尝试重现下面的情况,其中我尝试同时运行三个函数。但是,我只能在第一个函数中的某个点之后运行第二个和第三个函数,因为它取决于第一个函数的值。对于本例,我使用了通道。这是我的代码:

package code
import "fmt"

func first(c chan string) {
    for i := 0; i < 10000; i++ {
        continue
    }
    test := "test"
    fmt.println(test)
    c <- test
    for i := 0; i < 10000; i++ {
        fmt.print(i)
    }
}

func second(c chan string) {
    msg:= <- c
    fmt.println(msg)
    if msg != "" {  // i need to run the whole of first before running second and third concurrently then
        fmt.println("second", msg)
        for i := 0; i < 10000; i++ {
            fmt.print(i)
        }
    }
}

func third(c chan string) {
    msg:= <- c
    fmt.println("third", msg)
    for i := 0; i < 10000; i++ {
        fmt.print(i)
    }
}
package main

import (
    "./code"
    "fmt"
    "sync"

    //"sync"
    "time"
)
func main() {
    start := time.Now()
    var wg sync.WaitGroup
    wg.Add(3)
    var c chan string = make(chan string)
    go func() {
        code.First(c)
        wg.Done()
    }()
    go func() {
        code.Second(c)
        wg.Done()
    }()
    go func() {
        code.Third(c)
        wg.Done()
    }()
    wg.Wait()
    end := time.Now()
    delta := end.Sub(start)
    fmt.Println("time", delta.Seconds())
}

目前,我陷入了僵局。有几个额外的问题 - 有没有办法首先检查通道给出的值,如果它们不是某些预期值,我首先完成运行第一个函数,然后同时运行第二个和第三个函数?本质上是一张像我在第二步添加的支票一样的支票?如果这是预期值,我希望在通道从第一个函数获取特定值后所有函数同时运行。


解决方案


你的主程序生成三个额外的 goroutine,然后等待所有三个 goroutine 发出信号(通过 wg.Done)它们已完成。所有三个 goroutine 加上 main 本身共享一个通道,您可以通过该通道一次发送一个 string 实例(并且您可以使用该通道发送恰好一个)。

一个 goroutine(调用 code.First)旋转一段时间,然后发送一个字符串。发送字符串后,该 goroutine 会打印许多数字,然后发出完成信号并退出。

另外两个 goroutine(调用 code.Secondcode.Third)立即阻塞等待接收字符串。具体取决于它们运行的​​时间以及获取字符串的人的变幻莫测,其中一个将获取 code.First 发送的字符串。另一个仍然被阻止。

无论哪一个获得一个字符串(当前始终为 "test"),都会打印其名称和许多数字,然后表示完成并退出。

无论哪个没有获取字符串,仍在等待字符串。同时,main 中的 wg.Wait 正在等待最后一次 wg.Done 调用,由于所有剩余的 goroutine 都在等待,因此该调用不再发生(现在只有这两个 - main 和没有调用的)得到字符串——左)。这是你的僵局。

看起来您希望两个 goroutine 都能接收到从 code.First 发送的字符串。但这种情况并没有发生:其中一个获得了字符串,而另一个则继续等待。 (没有承诺获得该字符串。)

当然:无论你得到什么字符串,你都有一个字符串。您可以用它进行任何您喜欢的操作,就像您已经将它与 "" 进行比较一样。

这只是编程的一个小问题。不过,如果您希望能够控制获取条消息,则每个接收 goroutine 需要一个通道。如果您创建两个单独的通道,code.First 可以同时使用这两个通道,并且可以在您喜欢的任何时间点向任一附加 goroutine 发送适当的消息。

好了,本文到此结束,带大家了解了《为何我无法前进?》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>