하나 이상의 goroutine이 끝날 때까지 기다리는 방법은 무엇입니까?

Question

package main 

var fooRunning = false 
var barRunning = false 

func foo() { 
    fooRunning = true 
    defer func() { fooRunning = false }() 
    if barRunning { 
     // wait for bar() to finish 
    } 
    ... 
} 

func bar() { 
    barRunning = true 
    defer func() { barRunning = false }() 
    if fooRunning { 
     // wait for foo() to finish 
    } 
    ... 
} 

go foo()을 실행하면 bar()이 끝날 때까지 기다려야하며, 그 반대의 경우도 마찬가지입니다. 가장 좋은 방법은 무엇입니까? 그것들은 또한 독립적으로 실행될 수 있습니다.

Answer 1

채널을 사용할 수 있습니다! 난 내 녹슨 이동에서 기억으로,이 줄 것이다 :

func foo() { 
    c := make(chan int) 
    go bar(c) 
    <-c 
} 

과 당신의 요구 사항이 어떤 구체적인 설계에 의해 안전하게 만족할 수없는 바

func bar(c chan int) { 
    // do stuff here 
    c <- 0 
} 

Answer 2

에 있습니다. 처방대로, foo과 bar이 동시 goroutines에서 실행되며, 둘 중 하나 또는 둘 다 시작된 경우 다른 하나는 완료 될 때까지 기다려야한다고 말합니다. 그것은 처방전이 너무 약합니다. foo이 시작된 후 끝나지 만 bar이 아직 실행되지 않으면 어떻게됩니까? bar 전혀 실행되지 않으면 어떻게됩니까? 또는 bar이 실행되면 foo이 실행되지 않으면 어떻게됩니까?

foo과 bar 모두 프로그램을 올바르게 시작하기 위해 시작해야하며 완료해야합니까? 그렇다면 당신이 처방하려는 내용을 짐작할 수 있습니다 : 진행하기 전에 모두 완료되기를 기다리는 barrier을 원합니다.

package main 

import (
    "fmt" 
    "sync" 
    "time" 
) 

func foo() { 
    fmt.Println("foo") 
} 

func bar() { 
    fmt.Println("bar") 
} 

func within(wg sync.WaitGroup, f func()) { 
    wg.Add(1) 
    go func() { 
     defer wg.Done() 
     f() 
    }() 
} 

func main() { 
    var wg sync.WaitGroup 
    within(wg, foo) 
    within(wg, bar) 
    wg.Wait() 
    fmt.Println("Both foo and bar completed.") 
} 

(That same example in the Playground) 여기, foo도 bar도 상호 인식

참고; 두 사람의 전화를 조화시키기 위해 전화 한 사람 만 있습니다. foo 및 bar 각각 종료하기 전에 adding itself to the group 및 waiting on it 먼저 각 기능, 매개 변수 sync.WaitGroup로여 닫거나 동의를 만드는 길을 당신을 이끌 수

원래 시도. 그 방법은 광기를 속인다.

만약 foo가 시작되고 bar이 WaitGroup에 자신을 추가 할 수있는 기회를하기 전에, foo 당신이 그들이 동시에 실행했다 주장, 또는 foo가 활성을 등록 할 수 있습니다 전에 bar 실행과 대화 할 수있다하더라도, bar 전에 종료됩니다 완료 상태. 다시 말하지만, 이것은 프로그램의 잘못 지정된 부분이기 때문에,이 두 함수의 상호 의존성이 아니라 상위 레벨의 장벽에 집중하는 것이 좋습니다.