Wie implementiert man Sperren mit Zeitüberschreitungen in Go mithilfe von Kanälen?

Mary-Kate Olsen
Freigeben: 2024-10-31 00:31:29
Original
952 Leute haben es durchsucht

How to Implement Locking with Timeouts in Go using Channels?

Sperren mit Timeouts in Go

Herausforderung:

Das Erlangen von Sperren in Go kann problematisch sein, insbesondere wenn es um Latenz geht -sensible Operationen. Die sync.Mutex-Schnittstelle bietet nur grundlegende Sperr- und Entsperrfunktionen ohne die Möglichkeit, Sperren bedingt oder innerhalb eines bestimmten Zeitrahmens zu erwerben.

Lösung:

Kanäle als Mutex verwenden:

Eine einfache und effektive Lösung besteht darin, Kanäle als Grundelemente für den gegenseitigen Ausschluss zu nutzen. Durch Erstellen eines Kanals mit einer Puffergröße von eins können Sie eine Sperre simulieren:

<code class="go">l := make(chan struct{}, 1)</code>
Nach dem Login kopieren

Sperrung:

Um die Sperre zu erhalten, senden Sie ein Signal an den Kanal:

<code class="go">l <- struct{}{}</code>
Nach dem Login kopieren

Entsperren:

Um die Sperre aufzuheben, empfangen Sie vom Kanal:

<code class="go"><-l</code>
Nach dem Login kopieren

Versuchen Sie es mit dem Sperren:

Um zu versuchen, mit einer Zeitüberschreitung zu sperren, verwenden Sie eine Select-Anweisung:

<code class="go">select {
case l <- struct{}{}:
    // lock acquired
    <-l
default:
    // lock not acquired
}</code>
Nach dem Login kopieren

Durch die Kombination dieses Ansatzes mit time.After() können Sie TryLock mit einer Frist implementieren:

<code class="go">select {
case l <- struct{}{}:
    // lock acquired
    <-l
case <-time.After(time.Minute):
    // lock not acquired
}</code>
Nach dem Login kopieren

Beispiel 1: Latenzempfindliche Vorgänge begrenzen

<code class="go">func (s *RPCService) DoTheThing(ctx context.Context, ...) ... {
  if AcquireLock(ctx.Deadline(), &s.someObj[req.Parameter].lock) {
    defer ReleaseLock(&s.someObj[req.Parameter].lock)
    ... expensive computation ...
  } else {
    return s.cheapCachedResponse[req.Parameter]
  }
}</code>
Nach dem Login kopieren

Beispiel 2: Statistiken mit Timeout aktualisieren

<code class="go">func (s *StatsObject) updateObjStats(key, value interface{}) {
  if AcquireLock(200*time.Millisecond, &s.someObj[key].lock) {
    defer ReleaseLock(&s.someObj[key].lock)
    ... update stats ...
    ... fill in s.cheapCachedResponse ...
  }
}

func (s *StatsObject) UpdateStats() {
  s.someObj.Range(s.updateObjStats)
}</code>
Nach dem Login kopieren

Mit diesem Ansatz können Sie Sperren bedingt erwerben und gleichzeitig Leistungs- und Ressourcennutzungsprobleme effektiv lösen.

Das obige ist der detaillierte Inhalt vonWie implementiert man Sperren mit Zeitüberschreitungen in Go mithilfe von Kanälen?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Neueste Artikel des Autors
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage
Über uns Haftungsausschluss Sitemap
Chinesische PHP-Website:Online-PHP-Schulung für das Gemeinwohl,Helfen Sie PHP-Lernenden, sich schnell weiterzuentwickeln!