Snippet

Ratenbegrenzung gleichzeitiger Operationen mit time.Ticker

In Go kann eine Ratenbegrenzung mithilfe von time.Ticker implementiert werden. Ein Ticker sendet in regelmäßigen Abständen ein Signal über seinen Kanal C. Indem wir vor der Verarbeitung jeder Anfrage aus ticker.C lesen, blockieren wir die Schleife bis zum nächsten Takt. Dies stellt sicher, dass Anfragen in einer gleichmäßigen, kontrollierten Geschwindigkeit verarbeitet werden, ohne nachgelagerte Dienste zu überlasten.

snippet.go

package main
 
import (
	"fmt"
	"time"
)
 
func processRequests(requests <-chan int, rate time.Duration) {
	ticker := time.NewTicker(rate)
	defer ticker.Stop()
 
	for req := range requests {
		<-ticker.C
		fmt.Printf("Processed request %d at %s\n", req, time.Now().Format("15:04:05"))
	}
}

Erklärung

ticker := time.NewTicker(rate)

Erstellt einen neuen Ticker, der Kanalsignale im angegebenen Zeitintervall liefert.

defer ticker.Stop()

Stellt sicher, dass die Ticker-Ressourcen beim Verlassen der Funktion freigegeben werden, um Ressourcenlecks zu vermeiden.

<-ticker.C

Blockiert die Ausführungsschleife, bis ein Takt vom Ticker-Kanal empfangen wird, wodurch die Verzögerung erzwungen wird.

Vorheriges Snippet Nächstes Snippet

Mehr Go-Übungen für Fortgeschrittene →

Ratenbegrenzung gleichzeitiger Operationen mit time.Ticker

Verwandt