Kan dezelfde []byte-buffer in meerdere goroutines…

Ja, dat is mogelijk, maar het is noodzakelijk om toegangssynchronisatie te garanderen om racecondities te voorkomen.

De meest voorkomende benaderingen:

Mutex (sync.Mutex) :

import "sync"

var buf []byte
var mu sync.Mutex

func processBuffer() {
    mu.Lock()
    defer mu.Unlock()
    // Veilige toegang tot buf
    // Bijvoorbeeld: buf = append(buf, data...)
}

func main() {
    // Initialiseer buf
    go processBuffer()
    go processBuffer()
    // ...
}

Kanalen (chan) :

Je kunt het eigendom van de buffer tussen goroutines overdragen of een kanaal gebruiken om toegang te coördineren.

import "bytes"

type BufferAccess struct {
    buf *bytes.Buffer // Pointer naar buffer voor gedeeld gebruik
    mu  sync.Mutex    // Mutex voor synchronisatie
}

func (ba *BufferAccess) Write(p []byte) (n int, err error) {
    ba.mu.Lock()
    defer ba.mu.Unlock()
    return ba.buf.Write(p)
}

func worker(ba *BufferAccess, data []byte) {
    ba.Write(data) // Veilige write via methode met mutex
}

func main() {
    sharedBuffer := &BufferAccess{buf: &bytes.Buffer{}}
    // Start goroutines, geef sharedBuffer door
    go worker(sharedBuffer, []byte("hello"))
    go worker(sharedBuffer, []byte("world"))
    // ...
}

Bufferpool (sync.Pool) :

Minder behoefte aan synchronisatie bij toegang tot de buffer zelf, als elke goroutine een buffer uit de pool haalt, gebruikt en teruggeeft.

import (
    "bytes"
    "sync"
)

var bufferPool = sync.Pool{
    New: func() interface{} {
        // Standaard buffer grootte
        return bytes.NewBuffer(make([]byte, 0, 1024))
    },
}

func processData(data []byte) {
    buf := bufferPool.Get().(*bytes.Buffer)
    defer bufferPool.Put(buf) // Buffer teruggeven aan de pool

    buf.Reset() // Buffer leegmaken voor gebruik
    buf.Write(data)
    // Verwerking van data in buffer
    // ...
}

func main() {
    go processData([]byte("message1"))
    go processData([]byte("message2"))
    // ...
}

Belangrijk: Het gebruik van een buffer zonder synchronisatie in een gelijktijdige omgeving leidt tot racecondities, wat kan resulteren in onvoorspelbaar gedrag en moeilijk te detecteren fouten.

Kan dezelfde []byte-buffer in meerdere goroutines worden gebruikt?