当前位置：首页 > 文章列表 > Golang > Go问答 > 为何我无法前进？

为何我无法前进？

来源：stackoverflow 2024-03-21 19:36:36 0浏览收藏

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

问题内容

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

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())
}

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