Wie erstelle ich mithilfe von Zeitüberschreitungen und Wiederholungsversuchen in Go einen Kontext?

php-Editor Beim Schreiben von Code stoßen wir häufig auf Situationen, in denen wir die Ausführungszeit einer Operation begrenzen oder es erneut versuchen müssen, wenn die Operation fehlschlägt. Die Go-Sprache bietet einen einfachen und leistungsstarken Mechanismus, den Kontext, der uns helfen kann, diese Anforderungen zu erfüllen. Durch die ordnungsgemäße Nutzung von Zeitüberschreitungen und Wiederholungsmechanismen können wir die Zuverlässigkeit und Stabilität des Codes verbessern und gleichzeitig das Benutzererlebnis verbessern. Im nächsten Artikel werden wir ausführlich besprechen, wie man Timeouts und Wiederholungsversuche nutzt, um Kontext in der Go-Sprache zu erstellen.

Frageninhalt

Ich versuche, in Go mithilfe von Zeitüberschreitungen und mehreren Wiederholungsversuchen einen Kontext zu erstellen. Hier ist das Codebeispiel

func readretry(port io.readwritecloser, timeout, cnt int) []byte {
    fmt.println("in read retry")
    for i := 0; i < cnt; i++ {
        fmt.println("read attempt:", i)
        res := readwithcontext(timeout, port)
        if res != nil {
            return res
        }
    }
    return nil
}

func readwithcontext(timeout int, port io.readwritecloser) []byte {
    fmt.println("in readwithcontext")
    fmt.println("opening channel")
    rcvch := make(chan []byte)
    ctx, cancel := context.withtimeout(context.background(), time.duration(time.second*time.duration(timeout)))
    defer cancel()

    go reader(ctx, port, rcvch)

    for {
        select {
        case <-ctx.done():
            fmt.println("reader: context cancelled")
            return nil
        case buf := <-rcvch:
            fmt.println("reader: got data")
            return buf
        }
    }
}

func reader(ctx context.context, port io.readwritecloser, rcvch chan []byte) {

    fmt.println("in reader")

    answ := make([]byte, 1024)
    buf := bytes.buffer{}
    var err error

    for {
        i := 0
        i, err = port.read(answ)
        if err != nil && err != io.eof {
            log.printf("port.read: %v", err)
        }
        if i != 0 {
            answ = answ[:i]
            buf.write(answ)
            if buf.bytes()[len(buf.bytes())-1] == delimiter {
                fmt.print("received: ")
                printbuf(buf.bytes())
                rcvch <- buf.bytes() //if there is no data in the first attempt, cannot write to the channel here!!
                return
            }
        }
    }
}

Dann rufe ich readretry result := readretry(port, 2, 5) // 2 Sekunden Timeout, 5 Wiederholungsversuche auf. Wenn die Daten jedoch beim ersten Mal nicht bereit sind, kann reader nicht auf rcvch schreiben. Vielleicht ist es voll? Warum? Wenn ich versuche, den Kanal am Ende der Ausführung von readwithcontext zu schließen, tritt ein Konflikt auf – es wird in einen geschlossenen Kanal geschrieben. Wo ist die Kollision? Es geht davon aus, dass readwithcontext jedes Mal als neue Instanz gestartet wird, wodurch eine neue Instanz von rcvch erstellt wird. Wenn reader aufgrund einer Zeitüberschreitung geschlossen wird, wurden alle Kettenfunktionen und ihre lokalen Variablen (einschließlich Kanäle) zerstört . Es scheint jedoch, dass ich einen Fehler gemacht habe. Wie kann man es also noch einmal versuchen? Sehen Sie, wie das Protokoll aussieht:

IN READ RETRY
Read attempt: 1
IN readWithContext
Opening channel
IN reader
Start reader
Received: 0x01 0x02 0x03 0x04 0x05 0x06 0x07 0x08 0x09 0x0d //<- data is received, but not written to the channel!!
reader: context cancelled

Workaround

Bei jedem erneuten Versuch werden ein neuer Leser und ein neuer Kanal erstellt. Wenn readWithContext eine Zeitüberschreitung hat, wartet der Leser immer noch und liest vielleicht irgendwann, aber jetzt hört niemand am anderen Ende des Kanals zu, sodass der Leser durchgesickert ist.

Es gibt eine reader-Goroutine und einen Kanal zum Lesen mit reader goroutine 和一个通道，使用 readWithContext. Sie müssen den Reader auch stoppen, wenn der Kontext abläuft und alle Wiederholungsversuche erschöpft sind.

Das obige ist der detaillierte Inhalt vonWie erstelle ich mithilfe von Zeitüberschreitungen und Wiederholungsversuchen in Go einen Kontext?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!