Rumah  >  Artikel  >  pembangunan bahagian belakang  >  Analisis mekanisme menyekat dan tidak menyekat Saluran Golang

Analisis mekanisme menyekat dan tidak menyekat Saluran Golang

WBOY
WBOYasal
2023-08-08 11:13:191346semak imbas

Golang Channels 的阻塞和非阻塞机制解析

Analisis mekanisme menyekat dan tidak menyekat Saluran Golang

Pengenalan:
Saluran ialah salah satu mekanisme komunikasi serentak yang penting di Golang, yang membolehkan komunikasi dan penyegerakan antara Goroutine yang berbeza. Apabila menggunakan Saluran, kami sering menghadapi situasi menyekat dan tidak menyekat. Artikel ini akan memperkenalkan mekanisme menyekat dan tidak menyekat Saluran, dan menggambarkan prinsip dan penggunaannya melalui contoh kod.

  1. Konsep asas menyekat dan tidak menyekat
    Dalam pengaturcaraan serentak, menyekat dan tidak menyekat adalah dua kaedah pemprosesan biasa. Ringkasnya, menyekat bermaksud bahawa apabila Goroutine cuba membaca atau menulis Saluran, jika Saluran tidak bersedia, maka Goroutine akan disekat sehingga Saluran tidak menyekat bermakna Goroutine tidak bersedia sama ada Saluran tersebut bersedia. Dalam kes ini, pelaksanaan diteruskan serta-merta.

Di Golang, kami boleh melaksanakan mekanisme menyekat dan tidak menyekat dalam dua cara berikut: menggunakan panjang Saluran dan menggunakan pernyataan pilih. Di bawah ini kami akan memperkenalkan mereka satu persatu.

  1. Gunakan panjang Saluran untuk mencapai penyekatan dan tidak disekat
    Untuk Saluran yang tidak ditimbal, panjangnya ialah 0. Apabila Goroutine cuba menulis data ke Saluran yang tidak dibuffer, jika tiada Goroutine lain menunggu untuk membaca pada Saluran yang sama, operasi tulis akan disekat sehingga Goroutine bersedia untuk membaca data. Begitu juga, apabila Goroutine cuba membaca data daripada Saluran tidak buffer, operasi baca akan disekat jika tiada Goroutine lain menunggu untuk menulis pada Saluran yang sama.

Contoh kod:

package main

import "fmt"

func main() {
    ch := make(chan int) // 创建一个无缓冲 Channel

    go func() {
        fmt.Println("开始写入数据")
        ch <- 1 // 写入数据到 Channel
        fmt.Println("数据写入成功")
    }()

    fmt.Println("等待读取数据")
    data := <-ch // 从 Channel 读取数据
    fmt.Println("读取到数据:", data)
}

Dalam kod di atas, kami mencipta Saluran ch tanpa buffer. Dalam fungsi utama, kami memulakan Goroutine yang menulis data ke Saluran ch. Dalam Goroutine utama, kami cuba membaca data daripada Saluran ch dan memandangkan tiada Goroutine lain menunggu untuk menulis di Saluran ini, operasi baca akan disekat. Operasi baca tidak akan diteruskan sehingga Goroutine yang menulis data selesai dilaksanakan. ch。在 main 函数中,我们启动了一个 Goroutine,该 Goroutine 会向 Channel ch 写入数据。在主 Goroutine 中,我们试图从 Channel ch 中读取数据,由于没有其他 Goroutine 在此 Channel 上等待写入,读取操作会被阻塞。直到写入数据的 Goroutine 执行完成后,读取操作才会继续执行。

  1. 利用 select 语句实现非阻塞
    除了利用 Channel 的长度实现阻塞和非阻塞之外,Golang 中还提供了 select 语句,使得我们可以更灵活地处理并发通信。

在 select 语句中,我们可以同时监听多个 Channel 的读取和写入操作。当一个或多个 Channel 准备好时,select 语句会随机选择一个可执行的操作进行执行。如果没有任何 Channel 准备好,那么 select 语句会进入阻塞状态,直到至少有一个 Channel 准备好。

代码示例:

package main

import "fmt"

func main() {
    ch1 := make(chan int)
    ch2 := make(chan int)

    go func() {
        ch1 <- 1
    }()

    go func() {
        ch2 <- 2
    }()

    fmt.Println("开始监听 Channel")
    select {
    case data := <-ch1:
        fmt.Println("从 ch1 中读取到数据:", data)
    case data := <-ch2:
        fmt.Println("从 ch2 中读取到数据:", data)
    }
}

在上述代码中,我们创建了两个 Channel ch1ch2

    Gunakan pernyataan pilih untuk mencapai tanpa sekatan

    Selain menggunakan panjang Saluran untuk mencapai penyekatan dan tanpa sekatan, Golang juga menyediakan kenyataan terpilih, membolehkan kami mengendalikan komunikasi serentak dengan lebih banyak secara fleksibel.

    Dalam pernyataan pilih, kami boleh memantau operasi baca dan tulis berbilang Saluran pada masa yang sama. Apabila satu atau lebih Saluran sedia, pernyataan pilih secara rawak memilih operasi boleh laku untuk pelaksanaan. Jika tiada Saluran sedia, kenyataan pilih akan memasuki keadaan menyekat sehingga sekurang-kurangnya satu Saluran sedia.

    Contoh kod:
  • rrreee
  • Dalam kod di atas, kami mencipta dua Saluran ch1 dan ch2, dan masing-masing memulakan dua Goroutine ke dua Saluran tersebut. Dalam Goroutine utama, kami menggunakan pernyataan pilih untuk memilih operasi boleh laku daripada berbilang Saluran. Memandangkan kedua-dua Saluran sudah sedia, penyataan pilih akan memilih secara rawak salah satu operasi boleh laku untuk pelaksanaan.
  • Kesimpulan:
Melalui pengenalan dan contoh kod artikel ini, kami telah mengetahui tentang mekanisme menyekat dan tidak menyekat Saluran Golang. Dalam pembangunan sebenar, kita perlu memilih kaedah yang sesuai mengikut keperluan dan senario yang berbeza. Sama ada menggunakan panjang Saluran atau menggunakan pernyataan pilih, mekanisme komunikasi serentak Golang boleh menyediakan keupayaan pemprosesan serentak yang fleksibel dan cekap. Apabila menulis program serentak, kita harus mempunyai pemahaman yang mendalam tentang mekanisme menyekat dan tidak menyekat, dan secara rasional memilih kaedah pemprosesan yang sesuai untuk memastikan ketepatan dan prestasi program.

Rujukan: 🎜🎜🎜https://gobyexample.com/channels🎜🎜https://go101.org/article/channel.html🎜🎜🎜(bilangan perkataan: 819 perkataan)🎜

Atas ialah kandungan terperinci Analisis mekanisme menyekat dan tidak menyekat Saluran Golang. 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