Go Academy · Lektion

Semaphore-Pattern

Nebenläufigkeit mit einem Channel als Semaphore begrenzen

Semaphore-Pattern ist eine kostenlose Go Academy-Lektion auf CoddyKit. Dies ist Lektion 3 von 4. Du kannst die komplette Lektion unten kostenlos lesen – dann übst du sie direkt im Browser mit einem integrierten Code-Editor und einem KI-Tutor rund um die Uhr. Sie ist Teil des Go Academy-Lernpfads, und dein Fortschritt wird über Web und CoddyKit-App synchronisiert. Der Go Academy-Kurs umfasst insgesamt 4 Lektionen.

Was ist ein Semaphore?

Ein Semaphore begrenzt die Anzahl der Goroutinen, die gleichzeitig eine Operation ausführen. Dadurch wird eine Erschöpfung von Ressourcen verhindert (z. B. zu viele offene Datenbankverbindungen oder ausgehende HTTP-Anfragen).

Gepufferter Channel als Semaphore

Ein gepufferter Channel mit der Kapazität N fungiert als Zähl-Semaphore. Zum Belegen senden Sie an den Channel (bei voller Kapazität wird blockiert); zum Freigeben empfangen Sie daraus.

sem := make(chan struct{}, 10)

func withSem(f func()) {
    sem <- struct{}{} // acquire
    defer func() { <-sem }() // release
    f()
}

Eine Goroutine pro Aufgabe mit Semaphore

Starten Sie eine Goroutine pro Aufgabe, begrenzen Sie aber die Nebenläufigkeit mit einem Semaphore:

sem := make(chan struct{}, 5)
for _, job := range jobs {
    sem <- struct{}{}
    go func(j Job) {
        defer func() { <-sem }()
        process(j)
    }(job)
}

Semaphore am Ende leeren

Leeren Sie nach dem Starten aller Goroutinen das Semaphore, um sicherzustellen, dass alle beendet sind, bevor Sie zurückkehren:

// After the loop, acquire all N slots (blocks until all goroutines release)
for i := 0; i < cap(sem); i++ {
    sem <- struct{}{}
}

golang.org/x/sync/semaphore

Verwenden Sie für ein gewichtetes Semaphore (z. B. bei Goroutinen mit unterschiedlichem Ressourcenbedarf) den Typ semaphore.Weighted:

s := semaphore.NewWeighted(100)
// acquire 10 units
if err := s.Acquire(ctx, 10); err != nil { return err }
defer s.Release(10)
// do work

Context-gesteuertes Belegen

Acquire des gewichteten Semaphores berücksichtigt einen Context und gibt einen Fehler zurück, wenn der Context abgebrochen wird, bevor das Semaphore verfügbar ist.

TryAcquire

s.TryAcquire(n) belegt n Einheiten nur, wenn sie sofort verfügbar sind, und gibt andernfalls false zurück. Dies ist für nicht blockierende Prüfungen nützlich.

Semaphore oder Worker-Pool

Ein Worker-Pool verfügt über eine feste Anzahl persistenter Goroutinen. Ein Semaphore ermöglicht es, Goroutinen bei Bedarf zu starten und gleichzeitig die Nebenläufigkeit zu begrenzen. Verwenden Sie ein Semaphore, wenn die Rate eintreffender Aufgaben stark schwankt.

Begrenzung der HTTP-Nebenläufigkeit

Umschließen Sie einen HTTP-Handler oder -Client mit einem Semaphore, um zu viele gleichzeitige ausgehende Anfragen oder eingehende Handler-Goroutinen zu verhindern.

Begrenzung von Datenbankverbindungen

Verwenden Sie statt eines Semaphores db.SetMaxOpenConns(n) und db.SetMaxIdleConns(m) – das sql-Paket verwaltet die Nebenläufigkeit des Verbindungspools intern.

Fairness von Semaphoren

Semaphoren auf Basis gepufferter Channels sind ungefähr fair (FIFO für Goroutinen, die beim Senden blockiert sind), aber nicht strikt garantiert fair. Das Paket für gewichtete Semaphoren bietet strengere Fairnessgarantien.

Kurzer Test

Wie implementiert ein gepufferter Channel einen Semaphor?

Zusammenfassung: Semaphor-Muster

Wichtige Punkte:

Gepufferter Channel sem := make(chan struct{}, N) für einfache Semaphore
Zum Erwerb senden, zum Freigeben empfangen; die Freigabe immer per defer ausführen
golang.org/x/sync/semaphore für die gewichtete, Context-bewusste Variante
errgroup.SetLimit für einfache Nebenläufigkeitslimits pro Gruppe verwenden

Häufig gestellte Fragen

Ist die Lektion „Semaphore-Pattern“ kostenlos?

Ja — der vollständige Text von „Semaphore-Pattern“ ist hier im Web kostenlos zu lesen. Um sie interaktiv zu üben (integrierter Code-Editor und 24/7 KI-Tutor) und den Rest des Go Academy-Kurses freizuschalten, upgrade auf CoddyKit PRO. Der Go Academy-Kurs umfasst insgesamt 4 Lektionen.

Was lerne ich in „Semaphore-Pattern“?

Nebenläufigkeit mit einem Channel als Semaphore begrenzen Du übst Go Academy mit praktischem Code, den du direkt im Browser ausführst, und ein 24/7 KI-Tutor beantwortet deine Fragen während du die Lektion bearbeitest.

Brauche ich Erfahrung, um Go Academy zu starten?

Keine Vorkenntnisse erforderlich. Go Academy auf CoddyKit ist für Anfänger bis fortgeschrittene Lernende strukturiert, sodass du hier starten oder von Anfang an beginnen und in deinem eigenen Tempo voranschreiten kannst. Dies ist Lektion 3 von 4.

Wie lange dauert die Lektion „Semaphore-Pattern“?

Die meisten CoddyKit-Lektionen dauern etwa 5–10 Minuten. Jede ist kompakt und interaktiv, sodass du stetig Fortschritte machst und genau dort weitermachst, wo du aufgehört hast – im Web und in der App.

Kann ich in dieser Go Academy-Lektion Code schreiben und ausführen?

Ja. Jede Go Academy-Lektion enthält einen integrierten Code-Editor, sodass du echten Code direkt in deinem Browser schreibst und ausführst und sofort KI-Feedback erhältst — ohne lokale Einrichtung erforderlich.

Alle Lektionen in diesem Kurs

Pipeline- und Stage-Patterns
errgroup für nebenläufige Fehlerbehandlung
Semaphore-Pattern
Leak-Erkennung und Abbruch

← Zurück zu Go Academy