Mengapakah Menggunakan sync.WaitGroup dengan Fungsi Luaran Membawa kepada Kebuntuan?

Menggunakan sync.WaitGroup dengan Fungsi Luaran

Dalam program, anda mungkin menghadapi masalah apabila menggunakan sync.WaitGroup dengan fungsi yang ditakrifkan di luar fungsi utama. Mari kita teroka situasi ini.

Masalah:

Pertimbangkan kod berikut:

<code class="go">package main

import (
    "fmt"
    "sync"
)

func main() {
    ch := make(chan int)
    var wg sync.WaitGroup
    wg.Add(2)
    go Print(ch, wg) //
    go func(){

        for i := 1; i <= 11; i++ {
            ch <- i
        }

        close(ch)
        defer wg.Done()
    }()

    wg.Wait() //deadlock here
}

// Print prints all numbers sent on the channel.
// The function returns when the channel is closed.
func Print(ch <-chan int, wg sync.WaitGroup) {
    for n := range ch { // reads from channel until it's closed
        fmt.Println(n)
    }
    defer wg.Done()
}</code>

Di sini, anda menyasarkan program mencetak nombor daripada 1 hingga 11, tetapi kadangkala hanya mencetak 1 hingga 10.

Analisis Ralat:

Anda menghantar salinan penyegerakan.WaitGroup ke fungsi Cetak, yang bermakna ia tidak memanggil kaedah Done() pada penyegerakan.WaitGroup yang anda tunggu dalam fungsi utama.

Penyelesaian:

Untuk menyelesaikan isu ini , kemas kini kod seperti berikut:

<code class="go">package main

import (
    "fmt"
    "sync"
)

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

    var wg sync.WaitGroup
    wg.Add(2)

    go Print(ch, &wg)

    go func() {
        for i := 1; i <= 11; i++ {
            ch <- i
        }
        close(ch)
        defer wg.Done()
    }()

    wg.Wait() //deadlock here
}

func Print(ch <-chan int, wg *sync.WaitGroup) {
    for n := range ch { // reads from channel until it's closed
        fmt.Println(n)
    }
    defer wg.Done()
}</code>

Ini memastikan fungsi Cetak memanggil kaedah Done() pada penyegerakan yang sama.WaitGroup yang anda tunggu dalam fungsi utama.

Sebagai alternatif, anda boleh menyusun semula kod anda untuk mengalih keluar pergantungan pada penyegerakan.WaitGroup dalam fungsi Cetak:

<code class="go">package main

import (
    "fmt"
)

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

    go func() {
        for i := 1; i <= 11; i++ {
            ch <- i
        }
        close(ch)
    }()

    for n := range ch { // reads from channel until it's closed
        fmt.Println(n)
    }
}</code>

Atas ialah kandungan terperinci Mengapakah Menggunakan sync.WaitGroup dengan Fungsi Luaran Membawa kepada Kebuntuan?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!