две подпрограммы проходные на том же канале

Question

У меня есть функция, которая, учитывая кусочек и массив, будет посылать элементы среза в канал один за одним

Link to playground

package main 

import (
    "fmt" 
) 

var list1 = []string{"1", "2", "4"} 

var list2 = []string{"11", "22", "44"} 

func throw(ch chan string, list []string) { 
    for _, el := range list { 
     fmt.Println("Thrown ", el) 
     ch <- el 

    } 
    close(ch) 
    return 
} 

func main() { 
    c := make(chan string) 
    go throw(c, list1) 
    go throw(c, list2) 
    for i := range c { 
     fmt.Println("received ", i) 
    } 
} 

В некоторых что канал закрыт, но одна из функций по-прежнему должна отправлять данные на него. Как я должен справиться с этим? Создание отдельного канала представляется наиболее разумным выбором здесь, но я хочу, чтобы обе данные проходили через один и тот же канал.

Answer 1

Go ожидает, что код на отправляющей стороне канала узнает, был ли канал закрыт или нет. Таким образом, код, подобный вашему фрагменту, где каждый горутин может закрыть канал без учета другого, является ошибкой.

Одним из решений является использование sync.WaitGroup для координации при завершении каждого горутинга и выполнения третьего горутинга. Таким образом, вы бы изменить вашу throw функцию, чтобы выглядеть примерно так:

func throw(ch chan string, list []string, wg *sync.WaitGroup) { 
    defer wg.Done() 
    // current body of function, without the close() call 
} 

И изменить код, который порождает goroutines к следующему:

var wg sync.WaitGroup 
wg.Add(2) 
go throw(c, list1, &wg) 
go throw(c, list2, &wg) 
go func() { 
    wg.Wait() 
    close(c) 
}() 

Таким образом, ваш канал будет закрыт только после того, как другой два гортани завершены. Вы можете поэкспериментировать с этой измененной версией вашего примера здесь: http://play.golang.org/p/nUiwjGglgU