В итоге решение получилось такое.
В main функции заранее создается канал на один тикет.
trs.Ticket = make(chan bool,1)
trs.TicketDelay = time.Duration(5000)
trs.TimeBlocking = time.Duration(1000)
trs.Ticket <- true
В который сразу пишется одно значение - билет-проходка.
В горутинах, которые что-то запрашивают и могут получить ошибки добавлен select для чтения из канал Ticket.
Логика такая: получили ошибку, идем в if, если ошибка подходит, идем в select, кто-то первый успевает прочитать (достать) ticket, выходит из select'а, идет в switch - решает (пытается решить) проблему.
Отдает тикет обратно, чтобы какая-нибудь другая горутина смогла им воспользоваться, если проблема не решилась (горутины опять получили ошибку).
Горутины, которым тикет не достался блокируются на канале-таймере (1 сек), затем возвращаются в цикл запросов и пробуют снова сделать запрос.
Если опять ошибка, опять кто-то берет тикет, кто-то ждет, ну и так до победного....
...
defer done.Wg.Done()
TASKLOOP:
for {
select {
case <-trs.ctx.Done():
YAPI = &YandexAPIError{500, "The task was canceled", trs.ctx.Err()}
break TASKLOOP
default:
resp, err := trs.API.Translate(task.Lang, task.Text)
... какой-то код
// смотрим что за ошибка, если из списка - пробуем решить
if contains([]int{401, 402, 404, 405, 406},
resp.Code) {
select {
// канал на один тикет - кто успел взять, тот и решает проблему
case <-trs.Ticket:
break // выходим из select и идем в switch
// здесь блокируемся, если билетика нет, а потом идем делать новый запрос
case <-time.After(trs.TimeBlocking * time.Millisecond):
goto TASKLOOP
}
}
switch resp.Code {
.... много других кейсов
case 405, 406: // 'Session is invalid', 'Session has expired',
trs.mutex.Lock()
log.Errorf("[SESSION][task:%d][code:%d] EXPIRED or INVALID %s",
task.Id, resp.Code, trs.API.Id)
change := trs.ChangeSession(resp) // меняем session id
trs.mutex.Unlock()
// если получилось взять из очереди новый ключ\session_id
if change {
log.Warnf("[CHANGE SESSION] %s", trs.API.Id)
// немножко тормозим отдачу билетика в канал
time.Sleep(trs.TicketDelay * time.Millisecond)
trs.Ticket <- true // возвращаем билетик обратно
goto TASKLOOP // идем на новый виток запросов
} else {
// ну если ничего не вышло - в очереди больше нет ключей\session_id
YAPI = &YandexAPIError{resp.Code, resp.Message, err}
log.Errorf("[CHANGE SESSION] %s", NotFoundAPISessionID)
trs.ctx.Cancel() // отменяем все задания
break TASKLOOP // завершаем горутину
}
}
} // конец цикла
if YAPI != nil {
task.Err = YAPI
done.TaskChan <- task
log.Errorf("[TRANSLATE][%d] FAIL %#v", task.Id, YAPI)
} else {
log.Debugf("[TRANSLATE][%d] DONE!", task.Id)
}
Не знаю, насколько это решение простое и гениальное, но я до него долго доходил :-)
Можно покритиковать. Всем спасибо за ответы.