DNK_C_C++_Go_Rust

#493_GO_ODP_Q18

Можно ли использовать один и тот же буфер []byte в нескольких горутинах?
Зачем может понадобиться использовать один и тот же буфер []byte в нескольких горутинах параллельно?
Что именно будем в защищать мьютексом в общем буфере?

Нет, напрямую нельзя безопасно использовать один и тот же срез байтов []byte одновременно несколькими горутинами без синхронизации.
Причина в том, что одновременный доступ к одному и тому же ресурсу (особенно запись) может привести к состоянию гонки (race condition), когда одна goroutine перезаписывает данные другой goroutine.

Однако можно обезопасить такой доступ с помощью механизмов синхронизации, таких как мьютексы (sync.Mutex), каналы (channel) или атомарные операции (atomic package).
Использование мьютекса позволит организовать безопасный параллельный доступ к общему буферу.

Зачем может понадобиться использовать один и тот же буфер []byte в нескольких горутинах параллельно?

Параллельное использование общего буфера может потребоваться в следующих ситуациях:
Разделение ресурсов памяти — когда общая память ограничена, и желательно уменьшить потребление оперативной памяти путём совместного использования одной большой области памяти разными частями программы.
Оптимизация производительности — общий буфер может использоваться для организации конвейеров обработки данных.
Одна goroutine записывает данные в буфер, другая считывает их оттуда, организуя параллельную обработку.
Буферизация данных — буферы могут служить для временного хранения результатов, полученных асинхронно, пока не завершатся другие этапы обработки.

Рассмотрим сценарий, где одна goroutine получает поток данных и сохраняет их в общий буфер, а другая goroutine отправляет эти данные дальше в сеть или файл.

Что именно будем защищать мьютексом в общем буфере?
Защищать придётся любую операцию, которая изменяет состояние буфера, а именно:
Операции записи (запись данных в буфер).
Операции чтения (чтение данных из буфера), если возможна ситуация конкурентного доступа на чтение и запись одновременно.

Пример безопасного использования буфера с мьютексом:

package main

import (
  "fmt"
  "sync"
)

func main() {
  var buffer []byte
  bufferMutex := sync.Mutex{}

  go func() {
    for i := 0; i < 10; i++ {
      bufferMutex.Lock()
      defer bufferMutex.Unlock()
      buffer = append(buffer, byte(i))
    }
  }()

  go func() {
    for len(buffer) < 10 {
      bufferMutex.Lock()
      if len(buffer) > 0 {
        fmt.Printf("%d\n", buffer[len(buffer)-1])
        buffer = buffer[:len(buffer)-1]
      }
      bufferMutex.Unlock()
    }
  }()

  // Ждём завершение всех горутин
  wg := &sync.WaitGroup{}
  wg.Add(2)
  wg.Done()
  wg.Done()
  wg.Wait()
}

Здесь обе горутины используют общую область памяти (buffer), защищённую мьютексом.
Мьютекс блокирует доступ к общим ресурсам во избежание состояний гонок.

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

11 viewsПавел "barracol", 18:14