Wie implementiert man eine Nachrichtenwarteschlange in Goroutine?

Wie implementiert man eine Nachrichtenwarteschlange in Goroutine? Verwenden Sie die Make-Funktion, um einen ungepufferten Kanal zu erstellen. Verwenden Sie den Operator <-, um Nachrichten zu senden. Verwenden Sie den Operator ->, um Nachrichten zu empfangen.

Wie implementiert man eine Nachrichtenwarteschlange in Goroutine?

Einführung

Goroutinen in Go sind leichte Nebenläufigkeitsprimitive, die zum Erstellen paralleler Ausführungscodes verwendet werden können. Eine Nachrichtenwarteschlange ist ein Kommunikationsmechanismus, der es Goroutinen ermöglicht, Nachrichten asynchron zu senden und zu empfangen. In diesem Tutorial wird die Verwendung von Kanälen zum Implementieren von Nachrichtenwarteschlangen in Go vorgestellt und ein praktischer Fall bereitgestellt.

Implementieren der Nachrichtenwarteschlange

Channel in Go ist eine bidirektionale Kommunikationspipeline, die zum Übertragen von Werten zwischen Goroutinen verwendet werden kann. Um einen Kanal zu erstellen, verwenden Sie die Funktion make. Zum Beispiel: make 函数。例如：

ch := make(chan int)

此代码创建一个无缓冲 channel，这意味着它一次只能容纳一个值。

发送消息

要发送消息，请使用 channel 的 <- 操作符。例如：

ch <- 42

此代码将值 42 发送到 channel。

接收消息

要接收消息，请使用 channel 的 -> 操作符。例如：

msg := <-ch

此代码将从 channel 接收一个值并将其存储在 msg

package main

import "time"

func main() {
    ch := make(chan int)
    go func() {
        for i := 0; i < 10; i++ {
            ch <- i
            time.Sleep(time.Second)
        }
        close(ch)
    }()
}

Eine Nachricht senden

package main

import "time"

func main() {
    ch := make(chan int)
    go func() {
        for {
            msg, ok := <-ch
            if !ok {
                break
            }
            time.Sleep(time.Second)
            println(msg)
        }
    }()
}

Nachrichten empfangen

rrreee

Das obige ist der detaillierte Inhalt vonWie implementiert man eine Nachrichtenwarteschlange in Goroutine?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!