Mari kita bercakap tentang Halangan di golang

Apabila menulis kod serentak, selalunya perlu memastikan penyegerakan antara berbilang goroutine dan token atau kunci bersama untuk mengelakkan persaingan data dan keadaan perlumbaan. Bahasa Go menyediakan beberapa mekanisme untuk mencapai penyegerakan ini melalui pakej chan dan penyegerakan, tetapi kadangkala ia tidak cukup fleksibel dan memerlukan kaedah penyegerakan yang lebih maju Dalam kes ini, halangan diperlukan.

Halangan ialah primitif penyegerakan yang digunakan untuk menunggu sekumpulan goroutin menyelesaikan operasi pada masa yang sama sebelum meneruskan operasi seterusnya Ini adalah mekanisme penyegerakan yang sangat biasa. Golang juga menyediakan mekanisme untuk melaksanakan halangan iaitu “Barrier”.

Prinsip penghalang adalah untuk membahagikan kumpulan goroutin kepada dua fasa Fasa pertama berhenti selepas setiap goroutine telah menyelesaikan tugasnya sendiri dan menunggu goroutine lain selesai menyelesaikan tugas mereka apabila berhenti dan menetapkan isyarat antara satu sama lain, semua goroutine menyambung semula pelaksanaan secara serentak.

Golang menyediakan jenis "WaitGroup" dalam pakej penyegerakan Gunakan kaedah Tambah untuk menambah bilangan goroutine menunggu Kaedah Selesai digunakan untuk mengurangkan kaunter ke WaitGroup selepas setiap goroutine menyelesaikan tugasan , kaedah Tunggu menyekat Sehingga kaunter jatuh ke sifar, iaitu, semua goroutine telah menyelesaikan tugas mereka, langkah seterusnya tidak akan diteruskan.

Walau bagaimanapun, WaitGroup mempunyai kelemahan Ia hanya boleh menunggu bilangan goroutin yang tetap untuk dilengkapkan Apabila goroutin baharu bergabung, kami tidak boleh menggunakannya. Pada masa ini, kita boleh menggunakan Barrier untuk menyelesaikan masalah ini.

Penghalang boleh digunakan dengan sebarang bilangan goroutin dan boleh melakukan sebarang operasi tertentu pada penghujung setiap peringkat. Ia mengandungi pembilang yang menunjukkan bilangan gorout yang sedang menunggu set operasi selesai, dan fungsi untuk dilaksanakan pada penghujung setiap peringkat.

Satu "kumpulan utas menunggu" di Golang boleh dilaksanakan menggunakan "WaitGroup" pakej penyegerakan:

var wg sync.WaitGroup

func worker() {
    defer wg.Done()
    // 执行自己的任务
}

func main() {
    for i := 0; i < n; i++ {
        wg.Add(1)
        go worker()
    }
    // 等待所有线程完成
    wg.Wait()
}

Sekarang, kami menggunakan "Barrier" untuk mencipta Contoh a goroutine yang boleh digunakan untuk perubahan:

package main

import "fmt"
import "sync"

func main() {
    b := sync.NewCond(&sync.Mutex{})
    done := make(chan bool)

    worker := func(id int) {
        defer func() {
            fmt.Printf("Worker %d done\n", id)
            done <- true
        }()
        fmt.Printf("Worker %d processing\n", id)
        b.L.Lock()
        b.Wait() // 等待阻塞直到b.Broadcast()被执行
        b.L.Unlock()
        fmt.Printf("Worker %d resumed\n", id)
    }

    go func() {
        for i := 0; i < 10; i++ {
            wg.Add(1)
            go worker(i)
        }
    }()

    go func() {
        for i := 0; i < 10; i++ {
            wg.Add(1)
            go worker(i)
        }
    }()

    go func() {
        wg.Wait()
        b.Broadcast()
    }()

    for i := 0; i < 20; i++ {
        <-done
    }
    fmt.Printf("All workers done\n")
}

Contoh ini menghasilkan 20 goroutine, dibahagikan kepada dua fasa Fasa pertama menunggu selepas setiap goroutine menyelesaikan tugasnya, dan fasa kedua Tunggu semua goroutine selesai sebelum. menjalankan operasi.

Apabila dua kumpulan gorouti dibuat, salah satu daripada gorouti memanggil "Tunggu" dan menyekat sehingga semua gorouti menyelesaikan tugas mereka. Apabila utas lain telah menyelesaikan tugas mereka, sekatan dikeluarkan dan isyarat dihantar ke semua gorout menggunakan "Siaran" untuk meneruskan langkah seterusnya.

Ringkasnya, Golang's Barrier membolehkan anda menyegerakkan operasi serentak pada tahap yang lebih maju dan menjadikan kod anda lebih mantap dan boleh dipercayai.

Atas ialah kandungan terperinci Mari kita bercakap tentang Halangan di golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!