Lecture de plusieurs valeurs de retour de goroutine

php Editor Apple La lecture de plusieurs valeurs de retour de goroutine est une opération courante dans le langage Go. Goroutine est un thread léger dans le langage Go qui peut réaliser une exécution simultanée. Dans certains cas, nous devons obtenir la valeur de retour d'un ou plusieurs goroutines pour un traitement ultérieur. Cette opération peut être réalisée en utilisant des canaux, qui constituent un mécanisme important de communication entre les goroutines. Grâce aux canaux, nous pouvons transmettre des données entre les goroutines et réaliser la synchronisation et la communication entre les coroutines. Dans cet article, nous détaillerons les conseils et considérations sur la façon de lire plusieurs valeurs de retour d'une goroutine.

Contenu de la question

J'essaie d'écrire wc(1) dans Go et j'essaie d'utiliser des goroutines pour calculer plus efficacement un grand nombre de fichiers d'entrée. Mon code fonctionne bien, mais j'ai du mal à implémenter un moyen de résumer les statistiques pour toutes les routines go. Comment puis-je transmettre des variables de fonction nl、nw、nc pour les principales et les agréger là-bas une fois que toutes les routines go ont terminé leur travail ?

package main

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

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

    for _, arg := range os.Args[1:] {
        go wc(arg, ch)
    }
    for range os.Args[1:] {
        fmt.Println(<-ch)
    }
    // Todo: summarize results...
}

func wc(arg string, ch chan<- string) {
    nl, nw, nc := 0, 0, 0

    file, err := os.Open(arg)
    if err != nil {
        fmt.Println("Can't open file: %v", err)
    }
    defer file.Close()

    scan := bufio.NewScanner(file)
    for scan.Scan() {
        nl++

        line := scan.Text()
        words := bufio.NewScanner(strings.NewReader(line))
        words.Split(bufio.ScanWords)
        for words.Scan() {
            nw++
        }

        runes := bufio.NewReader(strings.NewReader(line))
        for {
            if _, _, err := runes.ReadRune(); err != nil {
                break
            } else {
                nc++
            }
        }
    }

    ch <- fmt.Sprintf("%8d%8d%8d", nl, nw, nc+nl)
}

Solution

Vous êtes proche de la réponse ! Je recommande un refactor rapide pour revenir Result 对象，这将允许轻松地在末尾添加它们（而不是使用字符串）。因此，您可以使用 chan 结果 而不是 chan string avec un numéro.

Fondamentalement, vous introduisez un résultat totalResult 变量，并且在迭代所有结果时，只需将 nl、nc 和 nw qui est ajouté à cette variable totale.

<code>package main

import (
    "fmt"
    "math/rand"
)

// define a struct to hold the result
type Result struct {
    nl int
    nw int
    nc int
}

// this is to be able to use fmt.Println(result)
func (r Result) String() string {
    return fmt.Sprintf("%8d%8d%8d", r.nl, r.nw, r.nc+r.nl)
}

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

    for _, arg := range os.Args[1:] {
        go wc(arg, ch)
    }

    totalResult := Result{}

    for range os.Args[1:] {
        result := <-ch
        fmt.Println(result) // just for debugging

        // sum everything
        totalResult.nl += result.nl
        totalResult.nw += result.nw
        totalResult.nc += result.nc
    }

    fmt.Println("Total result:")
    fmt.Println(totalResult)
}

func wc(arg string, ch chan<- Result) {
    nl, nw, nc := 0, 0, 0

    // your logic to compute nl, nw, nc goes here

    ch <- Result{nl: nl, nw: nw, nc: nc + nl}
}
</code>

Vous devriez obtenir quelque chose comme ceci (contenant 3 fichiers) :

37      50    4753
      19     106     821
      47     255    3806
Total result:
     103     411    9380

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!