func WithTimeout

func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc)

WithTimeout возвращает WithDeadline(parent, time.Now().Add(timeout)).

Отмена текущего контекста освобождает связанные с ним ресурсы, поэтому код должен вызывать cancel, как только операции исполняемые в этом Context выполнятся.

func slowOperationWithTimeout(ctx context.Context) (Result, error) {
    ctx, cancel := context.WithTimeout(ctx, 100*time.Millisecond)
    defer cancel()  // освобождает ресурсы, если slowOperation завершается до истечения таймаута
    return slowOperation(ctx)
}

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

package main

import (
    "context"
    "fmt"
    "time"
)

func main() {
    // Передайте контекст с таймаутом, чтобы сообщить функции блокировки, 
    // что он должен завершить работу после истечения таймаута.
    ctx, cancel := context.WithTimeout(context.Background(), 50*time.Millisecond)
    defer cancel()

    select {
    case <-time.After(1 * time.Second):
        fmt.Println("overslept")
    case <-ctx.Done():
        fmt.Println(ctx.Err()) // вывод "context deadline exceeded"
    }

}

results matching ""

    No results matching ""