Kebocoran Goroutine adalah masalah pekerjaan sumber kerana kegagalan keluar dengan betul. Sebab -sebab biasa termasuk tidak menutup saluran, tiada penerima yang menyebabkan penyumbatan menghantar, dan lain -lain. Pembaikan adalah untuk menutup saluran dalam masa, memastikan menghantar dan menerima pasangan, atau menggunakan mekanisme masa tamat. Kebocoran boleh dikesan melalui PPROF atau Runtime.NumGoroutine (). Amalan terbaik adalah menggunakan konteks untuk mengawal kitaran hayat dan memastikan setiap goroutine mempunyai laluan keluar yang jelas.

Kebocoran Goroutine di Go bermakna bahawa goroutine yang bermula tidak boleh keluar secara normal atas sebab tertentu, menyebabkan mereka menyekat atau menunggu, dengan itu menduduki sumber memori dan sistem untuk masa yang lama. Walaupun GO mempunyai mekanisme pengumpulan sampah, GC tidak akan mengitar semula goroutin yang masih berjalan atau menyekat, dan dari masa ke masa ia boleh menyebabkan kebocoran memori atau kemalangan perkhidmatan.

Berikut adalah contoh ujian goroutine yang tipikal, menerangkan kaedah penyebab dan pembaikannya.

? Contoh: Saluran yang tidak ditutup menyebabkan goroutine menerima menyekat

 Pakej utama

import (
    "FMT"
    "Masa"
)

func main () {
    CH: = Buat (chan int)

    // Mulakan goroutine untuk menerima data pergi func () {
        untuk nilai: = julat ch {
            fmt.println ("diterima:", nilai)
        }
    } ()

    // Hantar beberapa nilai ch <- 1
    CH <- 2

    // Lupa Tutup (CH) - Soalan utama!

    // coroutine utama tidak aktif, perhatikan masa kebocoran.Sleep (5 * time.second)
    fmt.println ("Main Done")
}

? Analisis Masalah:

• for range ch akan menunggu data baru dalam saluran.
• Coroutine utama tidak mempunyai close(ch) , dan goroutine yang diterima tidak akan keluar.
• Walaupun fungsi main berakhir, goroutine masih disekat, menyebabkan goroutine bocor .

Nota: Walaupun hujung main , program ini akan keluar secara langsung, tetapi dalam perkhidmatan sebenar (seperti perkhidmatan web), goroutine tersebut akan berkumpul.

? Kaedah Pembaikan: Tutup saluran dalam masa

 Pakej utama

import (
    "FMT"
    "Masa"
)

func main () {
    CH: = Buat (chan int)

    pergi func () {
        untuk nilai: = julat ch {
            fmt.println ("diterima:", nilai)
        }
        fmt.println ("Penerima keluar ...")
    } ()

    CH <- 1
    CH <- 2
    Tutup (ch) // Tutup saluran dengan betul untuk membuat jarak akhir.
}

? output:

 Diterima: 1
Diterima: 2
Penerima keluar ...
Utama selesai

Pada masa ini, Goroutine boleh keluar secara normal dan tidak akan bocor.

? Satu lagi senario kebocoran biasa: Goroutine sedang menunggu untuk dihantar ke saluran tanpa penerima

 Pakej utama

Import "Masa"

func main () {
    CH: = Buat (chan int)

    pergi func () {
        ch <- 100 // menyekat: tiada penerima} ()

    time.sleep (2 * time.second)
    // tanpa penerima, blok goroutine selamanya}

? Soalan:

• Hantar data ke saluran yang tidak dibebankan, tetapi tidak ada Goroutine lain yang diterima.
• Operasi hantar <- ch disekat secara serentak, dan goroutine akan terjebak selama-lamanya.

? Kaedah pembaikan:

Pastikan terdapat penerima, atau gunakan mekanisme masa tamat saluran Buffered.

 pergi func () {
    pilih {
    kes ch <- 100:
        fmt.println ("Dihantar dengan jayanya")
    kes <-time.after (1 * time.second):
        fmt.println ("Hantar tamat, elakkan menyekat")
    }
} ()

? Bagaimana untuk mengesan kebocoran goroutine?

1. Gunakan alat pprof :

    Import _ "bersih/http/pprof"
   Import "NET/HTTP"
   
   func main () {
       pergi func () {
           http.listenandserve ("localhost: 6060", nil)
       } ()
       // ... kod anda
   }

   Kemudian lawati http://localhost:6060/debug/pprof/goroutine untuk melihat bilangan goroutine semasa.

2. Gunakan runtime.NumGoroutine() semasa ujian :

    fmt.println ("goroutines:", runtime.numgoroutine ())

   Bandingkan nombor sebelum dan selepas laluan kritikal untuk menentukan sama ada pertumbuhan tidak normal.

   ---

   Untuk meringkaskan punca kebocoran yang biasa:

   • ? terlupa saluran close , menyebabkan range atau disekat secara kekal
   • ? Mula Goroutine untuk menghantar data, tetapi tidak ada penerima
   • ? Gunakan select tetapi beberapa kes tidak boleh mencetuskan
   • ? goroutine menunggu acara yang tidak pernah berlaku (seperti konteks tidak dibatalkan)

   ---

   Cadangan Amalan Terbaik:

   • Gunakan context.Context untuk mengawal kitaran hayat goroutine
   • Pastikan setiap goroutine dilancarkan mempunyai laluan keluar yang jelas
   • Anda perlu memasangkan operasi saluran: jika ada penghantaran, ada penerimaan, dan jika terdapat julat, ada dekat
   • Pantau perubahan nombor goroutine semasa ujian

   ---

   Pada dasarnya situasi biasa ini. Kebocoran Goroutine tidak selalu muncul dengan serta-merta, tetapi mereka sangat berbahaya dalam perkhidmatan jangka panjang dan memerlukan penjagaan khas.

   Atas ialah kandungan terperinci Contoh kebocoran Goroutine. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!