Adakah masa.Sleep() Benar-benar Menyekat Goroutine dan Pengurusan Benang Kesan dalam Penjadual Go?

Goroutines dan Pengurusan Benang mengikut masa.Sleep()

Dalam Go, goroutine ialah utas ringan yang diuruskan oleh penjadual masa jalan. Satu fungsi yang biasa digunakan untuk mengawal pelaksanaan goroutine ialah masa.Sleep(), yang menyekat pelaksanaan goroutine semasa untuk tempoh tertentu. Walau bagaimanapun, ini menimbulkan persoalan sama ada masa.Sleep() benar-benar menyekat goroutine dan menjejaskan pengurusan rangkaian dalam penjadual Go.

Memahami Penyekatan Goroutine

Ya, masa. Sleep() menyekat goroutine. Apabila dipanggil, ia menjeda pelaksanaan goroutine semasa untuk tempoh yang ditentukan. Pada masa ini, goroutine tidak boleh melakukan sebarang operasi atau bertindak balas kepada acara.

Pembuatan Thread dan masa.Sleep()

Bilangan urutan yang dibuat dalam proses Go dipengaruhi oleh pelbagai faktor, termasuk teras CPU yang tersedia, tetapan GOMAXPROCS dan beban kerja. Apabila time.Sleep() digunakan, ia tidak semestinya membawa kepada penciptaan rangkaian baharu.

Penjadual masa jalan Go memanfaatkan "model MPG" (berbilang proses, berbilang goroutin) untuk mengurus goroutin dan utas. Dalam model ini, M (berbilang) goroutin berkongsi P (berbilang) benang. Apabila goroutine disekat, benang P yang berkaitan boleh dilepaskan untuk memberi perkhidmatan kepada gorouti lain.

Contoh Analisis Kod

Mari kita periksa contoh kod yang disediakan:

import (
    "runtime"
    "time"
)

func main() {
    runtime.GOMAXPROCS(4)
    ch := make(chan int)
    n := 1
    for i := 0; i < n; i++ {
        go func() {
            time.Sleep(60 * time.Second)
            ch <- 1
        }()
    }
    for i := 0; i < n; i++ {
        <-ch
    }
}

Dalam contoh ini:

• Kami menetapkan GOMAXPROCS kepada 4, yang mengehadkan bilangan utas aktif kepada 4.
• Kami mencipta n goroutine, di mana setiap goroutine tidur selama 60 saat dan kemudian menghantar nilai ke saluran.
• Kami menunggu setiap goroutine selesai dengan menerima nilai daripada saluran.

Apabila n ialah 1, kami memerhati 5 utas dalam proses, memastikan bahawa terdapat sekurang-kurangnya satu utas untuk setiap goroutine yang sedang berjalan. Apabila n bertambah, bilangan utas kekal agak rendah kerana penjadual menguruskan utas P dengan cekap untuk memberi perkhidmatan berbilang gorouti yang disekat.

Perbezaan dengan IO Eksplisit

Dalam contoh kedua disediakan:

import (
    "fmt"
    "io/ioutil"
    "os"
    "runtime"
    "strconv"
)

func main() {
    runtime.GOMAXPROCS(2)
    data := make([]byte, 128*1024*1024)
    for i := 0; i < 200; i++ {
        go func(n int) {
            for {
                err := ioutil.WriteFile("testxxx"+strconv.Itoa(n), []byte(data), os.ModePerm)
                if err != nil {
                    fmt.Println(err)
                    break
                }
            }
        }(i)
    }
    select {}
}

Kami mencipta 200 goroutine yang terus menulis ke fail. Dalam kes ini, walaupun goroutin tidak disekat secara eksplisit mengikut masa.Sleep(), operasi IO menyebabkan goroutin terhenti, yang membawa kepada penciptaan lebih banyak benang (202 dalam contoh ini). Ini menyerlahkan kesan operasi tidak menyekat pada penciptaan benang.

Kesimpulan

Penjadual masa jalan Go menguruskan penciptaan benang dan pelaksanaan goroutine dengan berkesan. time.Sleep() menyekat goroutine, tetapi bilangan utas yang dicipta adalah dinamik dan dipengaruhi oleh beban kerja. Pembangun tidak seharusnya mengambil berat tentang pengurusan benang melainkan mereka menghadapi keadaan yang melampau di mana langkah eksplisit perlu diambil untuk mengawal penggunaan benang. Dalam kebanyakan kes, penjadual akan mengendalikan aspek ini secara automatik.

Atas ialah kandungan terperinci Adakah masa.Sleep() Benar-benar Menyekat Goroutine dan Pengurusan Benang Kesan dalam Penjadual Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!