Membaca berbilang nilai pulangan daripada goroutine

Editor PHP Apple Membaca berbilang nilai pulangan daripada goroutine ialah operasi biasa dalam bahasa Go. Goroutine ialah utas ringan dalam bahasa Go yang boleh mencapai pelaksanaan serentak. Dalam sesetengah kes, kita perlu mendapatkan nilai pulangan daripada satu atau lebih goroutine untuk pemprosesan selanjutnya. Operasi ini boleh dicapai dengan menggunakan saluran, yang merupakan mekanisme penting untuk komunikasi antara goroutine. Melalui saluran, kami boleh menghantar data antara goroutine dan mencapai penyegerakan dan komunikasi antara coroutine. Dalam artikel ini, kami akan memperincikan petua dan pertimbangan tentang cara membaca berbilang nilai pulangan daripada goroutine.

Kandungan soalan

Saya cuba menulis wc(1) dalam Go, dan saya cuba menggunakan goroutine untuk mengira sejumlah besar fail input dengan lebih cekap. Kod saya berfungsi dengan baik, tetapi saya menghadapi masalah melaksanakan cara untuk meringkaskan statistik untuk semua rutin pergi. Bagaimanakah saya boleh menghantar pembolehubah fungsi nl、nw、nc ke utama dan agregatnya di sana selepas semua rutin pergi telah menyelesaikan kerja mereka?

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)
}

Penyelesaian

Anda hampir dengan jawapannya! Saya syorkan refactor cepat untuk mengembalikan Result 对象，这将允许轻松地在末尾添加它们（而不是使用字符串）。因此，您可以使用 chan 结果 而不是 chan string dengan nombor.

Pada asasnya, anda memperkenalkan hasil totalResult 变量，并且在迭代所有结果时，只需将 nl、nc 和 nw yang ditambah kepada jumlah pembolehubah itu.

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

Anda sepatutnya mendapat sesuatu seperti ini (mengandungi 3 fail):

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

Atas ialah kandungan terperinci Membaca berbilang nilai pulangan daripada goroutine. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!