func WithCancel

func WithCancel(parent Context) (ctx Context, cancel CancelFunc)

WithCancel возвращает копию родителя с новым Done-каналом. Канал Done возвращаемого контекста закрывается, когда вызывается функция отмены или когда канал Done родительского контекста закрыт, в зависимости от того, что произойдет раньше.

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

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

package main

import (
    "context"
    "fmt"
)

func main() {
    // Gen создает целые числа в отдельной горутине и отправляет их на возвращаемый канал.
    // Коллерам gen необходимо отменить контекст после того, как они выполнятся
    gen := func(ctx context.Context) <-chan int {
        dst := make(chan int)
        n := 1
        go func() {
            for {
                select {
                case <-ctx.Done():
                    return // returning not to leak the goroutine
                case dst <- n:
                    n++
                }
            }
        }()
        return dst
    }

    ctx, cancel := context.WithCancel(context.Background())
    defer cancel() // выйти, когда закончится потребление целых чисел

    for n := range gen(ctx) {
        fmt.Println(n)
        if n == 5 {
            break
        }
    }
}

results matching ""

    No results matching ""