Rumah > pembangunan bahagian belakang > Golang > Bagaimana untuk Menutup Berbilang Goroutine dengan Anggun dalam Pergi Apabila Ralat Berlaku?

Bagaimana untuk Menutup Berbilang Goroutine dengan Anggun dalam Pergi Apabila Ralat Berlaku?

Patricia Arquette
Lepaskan: 2024-12-07 12:03:16
asal
667 orang telah melayarinya

How to Gracefully Shutdown Multiple Goroutines in Go When an Error Occurs?

Penutupan Berbilang Goroutine dengan Anggun dalam Go

Aplikasi In Go, menyelaraskan penutupan berbilang goroutine adalah penting untuk memastikan penamatan bersih dan segerak mereka. Artikel ini meneroka isu penyegerakan dua goroutin untuk kembali bersama apabila berlakunya ralat dalam mana-mana rutin.

Pertimbangkan coretan kod berikut:

func main() {

  go func() {
    ...
    if err != nil {
      return
    }
  }()

  go func() {
    ...
    if err != nil {
      return
    }
  }()


}
Salin selepas log masuk

Senario ini memerlukan penyegerakan goroutin supaya apabila salah seorang daripada mereka menghadapi ralat dan kembali, yang lain juga harus ditamatkan. Cabarannya terletak pada mencapai matlamat ini tanpa memperkenalkan tulisan ke saluran tertutup, yang boleh mengakibatkan panik.

Penyelesaian yang sangat berkesan melibatkan penggunaan pakej konteks Go untuk komunikasi antara goroutine. Dengan mencipta konteks dan menghantarnya ke setiap goroutine, anda boleh menyediakan mekanisme untuk menandakan penamatan mereka. Berikut ialah coretan kod yang dikemas kini yang menunjukkan pendekatan ini:

package main

import (
    "context"
    "sync"
)

func main() {

    ctx, cancel := context.WithCancel(context.Background())
    wg := sync.WaitGroup{}
    wg.Add(3)
    go func() {
        defer wg.Done()
        for {
            select {
            // msg from other goroutine finish
            case <-ctx.Done():
                // end
            }
        }
    }()

    go func() {
        defer wg.Done()
        for {
            select {
            // msg from other goroutine finish
            case <-ctx.Done():
                // end
            }
        }
    }()

    go func() {
        defer wg.Done()
        // your operation
        // call cancel when this goroutine ends
        cancel()
    }()
    wg.Wait()
}
Salin selepas log masuk

Dalam kod ini, pembolehubah konteks ctx berfungsi sebagai saluran komunikasi antara goroutine. Apabila ralat berlaku dalam mana-mana goroutine, ia memanggil cancel() pada konteks, yang memberi isyarat kepada goroutine lain untuk ditamatkan. Penyelesaian elegan ini memastikan penutupan yang anggun semua goroutine tanpa risiko panik.

Atas ialah kandungan terperinci Bagaimana untuk Menutup Berbilang Goroutine dengan Anggun dalam Pergi Apabila Ralat Berlaku?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

sumber:php.cn
Kenyataan Laman Web ini
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
Artikel terbaru oleh pengarang
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan