error) {
ctx, cancel := context.WithTimeout(context.Background(), timeLimit*time.Second)
defer cancel()
resultC, errC := c.cli.ContainerWait(ctx, containerID, "")
select {
case err := <-errC:
return 0, err
case result := <-resultC:
return result.StatusCode, nil
}
}
Вот такая функция. В теории должна прерывать ContainerWait спустя timeLimit*time.Second, но этого не происходит. ЧЯДНТ? Ощущение, что я чего-то не понимаю в использовании context.
чтобы контекст что-то “прервал” - надо регулярно пытаться читать из его канала, и, когда прочтется, завершаться
В доке WithTimeout есть вот такой пример: func main() { ctx, cancel := context.WithTimeout(context.Background(), 3 * time.Second) defer cancel() select { case <-time.After(1 * time.Second): fmt.Println("overslept") case <-ctx.Done(): fmt.Println(ctx.Err()) // prints "context deadline exceeded" } } ...но я его напрочь не понимаю. Что здесь происходит?
здесь мы читаем из двух каналов, какой быстрее прочтется - тот и выиграл
А если в оба пришли
рандомно выберет
Обсуждают сегодня