Как сообщить стурктурам об ошибке в одной из них?

Question

[oke11o]

У меня есть 8 горутин, в каждой из которых создается структура с подключением.
Если в одном подключении возникла непредвиденная ошибка, мне необходимо закрыть это подключение и сообщить остальным подобным структурам, чтобы они тоже закрылись.
Как это сделать?
У меня получилось такое решение. Но она кажется громоздким.

// Publish is method for use in goroutines
func Publish(in <-chan []byte, goroutines int, config Config) {
    
    done := make(chan bool, goroutines - 1)
    stop := make(chan bool, goroutines - 1)
    defer func () {
        close(done)
        close(done)
    } ()
    
    var wg sync.WaitGroup
    for i := 0; i < goroutines; i++ {
        wg.Add(1)
        go func(wg *sync.WaitGroup, in <-chan []byte, stop, done chan bool, config Config) {
            defer wg.Done()
            
            var conn connect
            conn.Init(config)
            conn.setDone(done)
            conn.setStop(stop)
            defer conn.close()
            
            for body := range in {
                conn.publishMessage(body)
            }
            
        } (&wg, in, stop, done, config)
    }
    go func (goroutines int, done <-chan bool, stop chan<- bool) {
        select {
        case <- done:
            for i := 0; i < goroutines - 1; i++ {
                stop <- true
            } 
        }
        
    } (goroutines, done, stop)
    wg.Wait()
}

Answer 1

[Никита]

Так это одно из первых, что нужно знать при конкурентном коде, юзайте контекст:
например, родной - https://godoc.org/golang.org/x/net/context
Или есть другие реализации, но их ещё понять нужно, стандартный попроще.

Comments

[spotifi]

Он не стандартный.
И не простой.

Но так, да, согласен, именно для подобной цели и предназначен.

Хотя....
Из пушки да по воробьям предлагаете...

[Владимир Грабко]

spotifi: он всё правильно говорит.

[spotifi]

Владимир Грабко: На контексте не будет круче чем на голых каналах. А лишная сущность - появляется.

[Владимир Грабко]

spotifi: мда.

[spotifi]

Владимир Грабко:
Жую специально для вас:
Как бы да - контекст здесь оправдан тем, что может использоваться в этой программе в других местах.
Но за ради одной этой описанной задачи - он не нужен.
Знаете такую штуку - проблема "карго"? Когда используют слишком мощные инструменты там, где это не надо.

[Владимир Грабко]

spotifi: так зачем писали о том что решение на каналах не торт?

[spotifi]

Владимир Грабко:
Я не это писал.

Я присал, что решение на контекстах - "много карго".

На каналах то как раз и следует.

[Владимир Грабко]

spotifi: простите. Перепутал с тем кто задал вопрос.

[oke11o]

То есть оставить на каналах? Я уже контекст пробую прикрутить.