Rumah >pembangunan bahagian belakang >Golang >Penjelasan terperinci tentang penggunaan dan contoh Go WaitGroup

Penjelasan terperinci tentang penggunaan dan contoh Go WaitGroup

王林
王林asal
2023-09-27 15:36:23989semak imbas

Go WaitGroup的使用方式及实例详解

Bahasa Go ialah bahasa pengaturcaraan dengan pengaturcaraan serentak sebagai terasnya dan sangat cekap dalam mengendalikan tugas serentak. Dalam pustaka standard bahasa Go, terdapat alat konkurensi yang sangat berguna-WaitGroup. Artikel ini akan memperkenalkan penggunaan WaitGroup secara terperinci dan menunjukkan aplikasi khususnya melalui contoh.

Pertama, kita perlu memahami peranan WaitGroup. WaitGroup digunakan untuk menunggu sekumpulan tugasan serentak selesai sebelum meneruskan untuk melaksanakan kod berikutnya. Biasanya, kita boleh menggunakan WaitGroup apabila coroutine utama perlu menunggu coroutine lain untuk menyelesaikan tugas tertentu sebelum meneruskan pelaksanaan.

Di bawah pakej penyegerakan bahasa Go, terdapat struktur WaitGroup, yang mempunyai tiga kaedah utama, iaitu Add(), Done() dan Wait(). Di bawah ini kami memperkenalkan fungsi mereka satu demi satu.

Yang pertama ialah kaedah Add(), yang digunakan untuk meningkatkan bilangan tugas menunggu. Kita boleh memberitahu WaitGroup berapa banyak tugasan yang perlu kita tunggu untuk disiapkan dengan memanggil kaedah Add(). Kaedah panggilan khusus ialah wg.Add(n), dengan n mewakili bilangan tugasan yang perlu ditunggu. Sebagai contoh, jika kita mempunyai 10 tugasan menunggu untuk diselesaikan, kita boleh memanggil wg.Add(10).

Kemudian terdapat kaedah Done() , yang digunakan untuk menandakan bahawa tugas semasa telah selesai. Apabila setiap tugas selesai, kaedah Done() perlu dipanggil untuk memberitahu WaitGroup bahawa tugas semasa telah selesai. Kaedah panggilan khusus ialah wg.Done(). Biasanya, kami akan memanggil kaedah Selesai() dalam penyata penangguhan selepas tugasan selesai untuk memastikan kaedah Selesai() akan dipanggil selepas tugasan selesai.

Akhir sekali ialah kaedah Tunggu(), yang digunakan untuk menyekat coroutine utama sehingga semua tugasan telah selesai. Apabila coroutine utama perlu menunggu satu set tugasan untuk diselesaikan sebelum meneruskan melaksanakan kod berikutnya, kaedah Tunggu() boleh dipanggil. Kaedah panggilan khusus ialah wg.Wait(). Kaedah Wait() akan menyekat sehingga semua tugasan telah selesai.

Di bawah ini kami menggunakan contoh untuk menunjukkan aplikasi khusus WaitGroup. Katakan kita mempunyai senarai tugasan yang perlu kita proses secara serentak. Selepas setiap tugasan selesai, kami menulis keputusan ke senarai keputusan. Akhir sekali, kita perlu menunggu sehingga semua tugasan selesai sebelum mencetak senarai keputusan. Kodnya adalah seperti berikut:

package main

import (
    "fmt"
    "sync"
)

func main() {
    var wg sync.WaitGroup
    taskList := []string{"task1", "task2", "task3", "task4"}

    // 创建结果列表
    resultList := make([]string, len(taskList))

    // 遍历任务列表,开启多个协程处理任务
    for i, task := range taskList {
        wg.Add(1) // 增加等待的任务数

        go func(index int, task string) {
            defer wg.Done() // 标志任务已经完成

            // 模拟任务处理过程
            result := fmt.Sprintf("task %s processed", task)

            // 将结果写入结果列表
            resultList[index] = result
        }(i, task)
    }

    wg.Wait() // 等待所有任务完成

    // 打印结果列表
    for _, result := range resultList {
        fmt.Println(result)
    }
}

Dalam kod di atas, mula-mula kita cipta objek WaitGroup wg. Kemudian, kami melintasi senarai tugasan dan memanggil wg.Add(1) sekali untuk setiap tugas, menunjukkan bahawa ada tugas yang perlu ditunggu. Dalam fungsi pengendali setiap tugasan, kami memanggil wg.Done() sekali selepas tugasan selesai. Akhirnya, kami memanggil wg.Wait() dalam coroutine utama untuk menunggu semua tugasan selesai.

Melalui reka bentuk ini, kami boleh memproses tugasan secara serentak dan memastikan bahawa selepas semua tugasan selesai, kami boleh meneruskan pelaksanaan coroutine utama yang seterusnya. Akhirnya, kami mencetak senarai keputusan untuk mengesahkan pemprosesan tugasan serentak dan ketepatan keputusan.

Ringkasnya, WaitGroup ialah alat serentak yang sangat praktikal dalam bahasa Go. Dengan menggunakan WaitGroup dengan betul, kami boleh mengurus tugas serentak dengan lebih baik dan memastikan susunan dan ketepatan tugasan. Saya harap artikel ini dapat membantu pembaca memahami dan menggunakan WaitGroup dengan lebih baik.

Atas ialah kandungan terperinci Penjelasan terperinci tentang penggunaan dan contoh Go WaitGroup. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn