Heim  >  Artikel  >  Backend-Entwicklung  >  Was ist die Golang-Synchronisationsmethode?

Was ist die Golang-Synchronisationsmethode?

PHPz
PHPzOriginal
2023-03-31 10:26:11792Durchsuche

Mit der kontinuierlichen Aktualisierung und Weiterentwicklung der Computertechnologie werden auch Programmiersprachen ständig aktualisiert und weiterentwickelt. Ein wichtiges Merkmal von Programmiersprachen ist die Unterstützung der gleichzeitigen Ausführung mehrerer Threads. Bei der gleichzeitigen Ausführung mehrerer Threads kommt es leicht dazu, dass verschiedene Threads sich gegenseitig stören oder gleichzeitig auf dieselbe Ressource zugreifen. In diesem Fall müssen Synchronisierungsmethoden verwendet werden, um das Problem zu lösen.

Golang ist eine Programmiersprache, die Multithread-Parallelität unterstützt. Viele Golang-Programmierer verwenden Synchronisationsmethoden, um Probleme beim gleichzeitigen Zugriff zu lösen.

Einführung in Synchronisationsmethoden

In Golang kann die Verwendung von Synchronisationsmethoden die Datensynchronisation zwischen verschiedenen Coroutinen und die Datenzugriffssicherheit zwischen mehreren Coroutinen gewährleisten. Durch den Einsatz von Synchronisationsmethoden können Programmierer Datenzugriffskonflikte vermeiden, wenn mehrere Coroutinen gleichzeitig ausgeführt werden. In Golang gibt es viele Möglichkeiten, Synchronisationsmethoden zu implementieren, einschließlich Mutex-Sperren, RWMutex-Sperren, Kanälen usw.

Mutex-Sperre

Mutex-Sperre ist die grundlegendste Synchronisierungsmethode in Golang. Sie bietet die grundlegendste Datensynchronisierungsmethode. Die Verwendung der Mutex-Sperre ist sehr einfach. Sie müssen lediglich vor der Coroutine eine Mutex-Sperre hinzufügen, um den Zweck der Coroutine-Synchronisation zu erreichen. Das Folgende ist ein Beispielcode mit Mutex-Sperre:

package main

import (
    "fmt"
    "sync"
)

var (
    count int
    lock sync.Mutex
)

func increment() {
    lock.Lock()
    count++
    lock.Unlock()
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            increment()
        }()
    }
    wg.Wait()
    fmt.Println(count)
}

Im obigen Code verwenden wir sync.Mutex, um die Coroutine-Synchronisation zu implementieren. In der Inkrementierungsfunktion verwenden wir lock.Lock und lock.Unlock, um die Anzahl zu sperren, um sicherzustellen, dass beim Zugriff mehrerer Coroutinen auf count nur eine Coroutine darauf zugreifen kann, wodurch Datenkonflikte durch gleichzeitigen Zugriff vermieden werden. In der Hauptfunktion öffnen wir 1000 Coroutinen, um die Inkrementierungsfunktion aufzurufen und schließlich den Wert von count auszugeben.

rwmutex-Sperre

Obwohl die Mutex-Sperre das Problem gleichzeitiger Zugriffskonflikte lösen kann, muss sie in einigen Szenarien sowohl Lesevorgänge als auch Schreibvorgänge unterstützen. Zu diesem Zeitpunkt müssen Sie die rwmutex-Sperre verwenden. Die rwmutex-Sperre in Golang ist eine Lese-/Schreibsperre, die die Sperre in zwei Typen unterteilt: Lesesperre und Schreibsperre. Die Lesesperre kann von mehreren Coroutinen gleichzeitig gehalten werden. Wenn jedoch die Schreibsperre gehalten wird, kann die Lesesperre nicht erworben werden, dh die Schreibsperre hat eine höhere Priorität als die Lesesperre.

Das Folgende ist ein Beispielcode, der die rwmutex-Sperre verwendet:

package main

import (
    "fmt"
    "sync"
)

var (
    count int
    lock sync.RWMutex
)

func read() {
    lock.RLock()
    defer lock.RUnlock()
    fmt.Println(count)
}

func write() {
    lock.Lock()
    defer lock.Unlock()
    count++
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            read()
        }()
    }

    wg.Add(1)
    go func() {
        defer wg.Done()
        write()
    }()
    wg.Wait()
}

Im obigen Code definieren wir eine Zählvariable und einen sync.RWMutex und verwenden die Lese- und Schreibfunktionen, um die Zählvariable zu lesen und zu schreiben. Wenn die Lesefunktion aufgerufen wird, verwenden wir lock.RLock, um die Lesesperre zu erhalten, sodass mehrere Coroutinen gleichzeitig den Wert der Zählvariablen lesen können. Wenn die Schreibfunktion aufgerufen wird, verwenden wir lock.Lock, um die Schreibsperre zu erhalten, sodass nur eine Coroutine den Wert der Zählvariablen schreiben kann. In der Hauptfunktion öffnen wir 10 Coroutinen, um die Lesefunktion aufzurufen, und eine Coroutine, um die Schreibfunktion aufzurufen.

channel

Neben der Mutex-Sperre und der RWmutex-Sperre gibt es in Golang noch eine weitere Synchronisationsmethode, nämlich den Kanal. Kanäle können verwendet werden, um Daten zwischen Coroutinen zu übertragen und die Ausführungsreihenfolge von Coroutinen zu synchronisieren. Es gibt drei Arten von Kanälen: ungepufferte Kanäle, gepufferte Kanäle und gerichtete Kanäle.

Das Folgende ist ein Beispielcode für die Verwendung eines Cache-freien Kanals:

package main

import (
    "fmt"
)

func main() {
    c := make(chan int, 1)
    go func() {
        c <- 1
    }()
    fmt.Println(<-c)
}

Im obigen Code verwenden wir die Make-Funktion, um einen Cache-freien Kanal zu erstellen und eine Coroutine zum Übertragen von Daten zum und vom Kanal zu definieren. In der Hauptfunktion lesen wir die Daten im Kanal über die Anweisung „<-c“.

Das Merkmal des Cache-freien Kanals besteht darin, dass Senden und Empfangen synchron sind, dh zwei Coroutinen müssen gleichzeitig bereit sein, bevor Sende- und Empfangsvorgänge ausgeführt werden, da sonst ein Deadlock auftritt.

Es gibt einen Unterschied zwischen einem zwischengespeicherten Kanal und einem nicht zwischengespeicherten Kanal. Ein zwischengespeicherter Kanal kann mehrere Elemente gleichzeitig speichern. Die Puffergröße ist die Größe, die beim Erstellen des Kanals initialisiert wird. Bei Verwendung eines gepufferten Kanals wird der Sendevorgang nur blockiert, wenn der Puffer voll ist, und der Empfangsvorgang wird nur blockiert, wenn der Puffer leer ist.

Ein Kanal mit Richtung kann verwendet werden, um die Lese- und Schreibrichtung des Kanals zu steuern. Er kann beispielsweise nur zum Schreiben von Daten oder nur zum Lesen von Daten verwendet werden.

Fazit

Die Golang-Synchronisationsmethoden umfassen drei Typen: Mutex-Sperre, RWMutex-Sperre und Kanal. Durch die Verwendung dieser Synchronisierungsmethoden können Sie sicherstellen, dass es zu keinen Datenzugriffskonflikten kommt, wenn mehrere Coroutinen gleichzeitig ausgeführt werden. In der tatsächlichen Entwicklung müssen Programmierer basierend auf tatsächlichen Szenarien unterschiedliche Synchronisierungsmethoden auswählen, um optimale Leistung und Zuverlässigkeit zu erzielen.

Das obige ist der detaillierte Inhalt vonWas ist die Golang-Synchronisationsmethode?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
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