Каналы в Go

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

Схема "много писателей - один читатель" может быть полезна в следующих случаях:
1. **Сбор данных**: Если несколько горутин генерируют данные, которые должны быть обработаны централизованно.
2. **Ограничение ресурсов**: Когда есть ресурс, который может быть использован только одной горутиной одновременно.
3. **Синхронизация**: Для синхронизации работы нескольких горутин, отправляющих данные одной горутине-обработчику.
4. **Упрощение конструкции**: Уменьшение сложности обработки, когда все данные собираются и обрабатываются в одном месте.

Аксиомы каналов Go

Отправка в nil канал блокируется навсегда.
Чтение из nil канала блокируется навсегда.
Отправка в закрытый канал вызывает панику.
Чтение из закрытого канала возвращает нулевое значение.

Семафор - реализация на каналах

Используется для:

- Ограничение доступа к общим ресурсам.

- Управление параллельным выполнением задач.

- Реализация паттернов синхронизации.
Этот код реализует семафор на языке Go. Семафоры используются для ограничения количества горутин, которые могут одновременно получить доступ к ресурсу или выполнить определенную задачу.

type semaphore struct {
semC chan struct{}
}
func New(maxConcurrency int) Semaphore {
return &semaphore{
semC: make(chan struct{}, maxConcurrency),
}
}
func (s *semaphore) Acquire() {
s.semC <- struct{}{}
}
func (s *semaphore) Release() {
<-s.semC
}

/*
- `New(maxConcurrency int)`: создает новый семафор с максимальной параллельностью `maxConcurrency`.
- `Acquire()`: захватывает слот в семафоре. Если все слоты заняты, горутина блокируется.
- `Release()`: освобождает слот, делая его доступным для других горутин.
*/