Heim > Backend-Entwicklung > Golang > Wie verwende ich Pipes in Go für nicht blockierende E/A?

Wie verwende ich Pipes in Go für nicht blockierende E/A?

WBOY
Freigeben: 2024-06-01 12:14:56
Original
773 Leute haben es durchsucht

Nicht blockierende E/A in der Go-Sprache kann durch die Verwendung von Pipes erreicht werden: Erstellen Sie eine ungepufferte Pipe: make(chan int) Senden Sie Daten an die Pipe: ch <- 1 Empfangen Sie Daten von der Pipe: val := < -ch Praktischer Fall: Erstellen Sie ein nicht blockierendes Dateileseprogramm

如何使用 Go 语言中的管道进行非阻塞 I/O?

Wie verwende ich Pipes in der Go-Sprache für nicht blockierende E/A?

Pipes sind eine effiziente Möglichkeit, in gleichzeitigen Go-Programmen zu kommunizieren. Sie ermöglichen ereignisbasierten Code, bei dem jede Phase unabhängig ausgeführt wird, während Daten asynchron durch die Pipeline fließen. In diesem Artikel wird gezeigt, wie Sie Pipes verwenden, um nicht blockierende E/A in der Go-Sprache zu implementieren.

Erstellung und Verwendung von Pipes

Das Erstellen einer Pipe ist sehr einfach: eine ungepufferte Pipe vom Typ

package main

import "fmt"

func main() {
    ch := make(chan int)
}
Nach dem Login kopieren

make(chan int) 创建一个可以容纳 int. Ungepuffert bedeutet, dass Daten sofort von einer Coroutine zur anderen übertragen werden, was für leistungsstarke I/O-Anwendungen von entscheidender Bedeutung ist.

Daten an die Pipe senden:

ch <- 1
Nach dem Login kopieren

Daten von der Pipe empfangen:

val := <-ch
Nach dem Login kopieren

Praktischer Fall: Dateilesen

Lassen Sie uns ein nicht blockierendes Dateileseprogramm erstellen. Angenommen, der Dateiinhalt lautet:

Hello
World
Nach dem Login kopieren
package main

import (
    "fmt"
    "bufio"
    "os"
)

func main() {
    ch := make(chan string)

    file, err := os.Open("file.txt")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer file.Close()

    go func() {
        scanner := bufio.NewScanner(file)
        for scanner.Scan() {
            ch <- scanner.Text()
        }
        ch <- "" // 标记文件读完
    }()

    // 从管道中以非阻塞方式读取行
    for {
        line := <-ch
        if line == "" {
            break
        }
        fmt.Println(line)
    }
}
Nach dem Login kopieren

Das Programm erstellt eine Pipe zum Übertragen der Dateizeilen. Eine Coroutine ist für das Lesen aus der Datei und das Senden von Zeilen an die Pipe verantwortlich. Die Haupt-Coroutine empfängt dann die Zeilen von der Pipe, und da die Pipe nicht blockierend ist, kann sie auch dann andere Aufgaben ausführen, wenn das Lesen der Datei noch nicht abgeschlossen ist.

Wenn das Lesen der Datei abgeschlossen ist, senden Sie eine leere Zeile, um die Haupt-Coroutine zu benachrichtigen, die Schleife zu verlassen.

Das obige ist der detaillierte Inhalt vonWie verwende ich Pipes in Go für nicht blockierende E/A?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Verwandte Etiketten:
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
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage