Während der Entwicklung von Liveapi, einem Tool zur Erzeugung von Auto -API -Dokumentationen, musste ich einen robusten Warteschlangenmechanismus implementieren, der basierend auf der Anzahl der Servermaschinenkernen skalierte. Dies war entscheidend, um eine übermäßige Nutzung von Ressourcen (Speicher und CPU) zu verhindern, die zu Ressourcenhunger, Abstürmen und einer schlechten Benutzererfahrung führen konnte.

In diesem Artikel werde ich erklären, wie ich Mutexes in Golang verwendet habe, um diese Herausforderung anzugehen.

.

Was ist ein Mutex?
Bei der gleichzeitigen Programmierung ist ein Mutex (gegenseitiger Ausschluss) ein Verriegelungsmechanismus, der die Rassenbedingungen verhindert, indem sichergestellt wird, dass nur eine Goroutine gleichzeitig auf eine gemeinsame Ressource zugreifen kann. Es ähnelt einem Schlüssel zu einem Raum - nur eine Person kann den Schlüssel halten und sofort eingeben.

mutex use in golang
Lassen Sie uns veranschaulichen, wie ein Mutex die gleichzeitige Ausführung von Arbeitsplätzen verwalten kann:
Das SYNC -Paket von Go bietet mehrere Primitive für die Synchronisation, wobei Mutex eines der am häufigsten verwendeten Tools ist.

var (
    maxConcurrentJobs int
    activeJobs        int
    jobMutex          sync.Mutex
)

In diesem Code verfolgt die ActiveJobs Variable die Anzahl der derzeit ausgeführten Jobs. Da mehrere Goroutinen möglicherweise versuchen, diese Variable gleichzeitig zu ändern, wodurch wir zu Rassenbedingungen führen, verwenden wir einen Mutex, um den Zugriff zu synchronisieren.

// Check if we can process more jobs
jobMutex.Lock()
if activeJobs >= maxConcurrentJobs {
    jobMutex.Unlock()
    // Wait before checking again
    time.Sleep(time.Second)
    continue
}
jobMutex.Unlock()

wie ein mutex funktioniert
sperren : Die methode lock () erhält exklusiven Zugriff auf den kritischen Abschnitt.

entsperre : Die methode entrichtet die Sperre.

Critical Section : auf den Code zwischen Sperre und Entsperren, bei dem die gemeinsame Ressource ** zugegriffen wird.

.

Arten von Mutexes in golang
Es ermöglicht nur eine Goroutine, nach einem Zeitpunkt auf den kritischen Abschnitt zuzugreifen.

Geben Sie SafeCounter Struct {ein mu sync.mutex Graf int }

type SafeCounter struct {
    mu    sync.Mutex
    count int
}

sync.rwmutex : Dies ist ein Leser/Schriftsteller -Mutex, mit dem mehrere Leser gleichzeitig auf die gemeinsame Ressource zugreifen können, aber nur ein Schriftsteller gleichzeitig.

var rwmutex sync.rwmutex // Lesermethoden rwmutex.rlock () // Sperren zum Lesen rwmutex.runlock () // zum Lesen entsperren // Writer -Methoden rwmutex.lock () // zum Schreiben sperren rwmutex.unlock () // zum Schreiben entsperren

type SafeCounter struct {
    mu    sync.Mutex
    count int
}

mustexes sind wesentliche Tools für die Verwaltung gemeinsamer Ressourcen in gleichzeitigen GO -Programmen. Sie verhindern Rennbedingungen und gewährleisten die Datenintegrität, indem sie den Zugriff auf kritische Codeabschnitte steuern.