Как спроектировать компонент, который безопасно завершает работу при параллельных вызовах Close?

Компоненты в конкурентных системах часто закрываются из разных частей программы.

Определение:
Идемпотентный Close — это метод, который можно вызывать несколько раз без побочных эффектов.

Основные требования

Компонент должен:

1. Закрываться только один раз.

2. Не вызывать panic.

3. Освобождать ресурсы корректно.

Подход 1 — sync.Once

Самый распространенный вариант:

type Worker struct {
    once sync.Once
}

func (w *Worker) Close() {
    w.once.Do(func() {
        // освобождение ресурсов
    })
}

Подход 2 — atomic флаг

Подходит для простых случаев:

if atomic.CompareAndSwapInt32(&closed, 0, 1) {
    // закрытие
}

Подход 3 — mutex

Используется, если логика сложнее:

1. Проверка состояния.

2. Закрытие.

3. Изменение флага.

Дополнительные элементы

Часто добавляют:

1. Context cancellation.

2. Канал завершения.

3. WaitGroup.

Вывод

Безопасный Close строится вокруг идемпотентности и синхронизации, чтобы гарантировать корректное освобождение ресурсов даже при параллельных вызовах.