Alat yang berkuasa untuk pengaturcaraan serentak di Golang: Saluran

Alat berkuasa untuk pengaturcaraan serentak di Golang: Saluran

Dalam pengaturcaraan serentak, komunikasi antara utas ialah teknologi yang sangat penting. Di Golang, Saluran telah menjadi primitif serentak yang sangat berguna.

Apakah itu Saluran?

Saluran ialah jenis yang disediakan oleh Golang untuk komunikasi dan pertukaran data antara Goroutine yang berbeza (benang ringan). Ia serupa dengan paip yang boleh menghantar data antara Goroutine yang berbeza.

Saluran diisytiharkan seperti berikut:

var ch chan T

di mana T mewakili jenis data penghantaran. Apabila mencipta saluran, anda perlu menggunakan fungsi make untuk permulaan:

ch := make(chan T)

Ciri-ciri Saluran

1. Keselamatan benang: Saluran melaksanakan mekanisme kunci mutex secara dalaman untuk memastikan persaingan dan konflik data tidak akan berlaku apabila berbilang Goroutine beroperasi secara serentak.
2. Ciri penyekatan: Apabila menghantar data (menulis) ke Saluran, jika Saluran penuh, operasi penghantaran akan disekat. Apabila menerima data (membaca) daripada Saluran, jika tiada data dalam Saluran, operasi penerimaan akan disekat.
3. First in first out (FIFO): Saluran mengikut prinsip first in first out apabila menghantar data.

Operasi Saluran

Saluran termasuk dua operasi asas: Hantar dan Terima.

Operasi penghantaran menggunakan operator <- untuk menghantar data ke Saluran:

ch <- data

Operasi penerimaan menggunakan operator <- untuk mendapatkan data daripada Saluran:

data <- ch

Contoh saluran

Mari lihat Contoh mudah menunjukkan cara menggunakan Saluran untuk memindahkan data antara dua Goroutine.

package main

import (
    "fmt"
    "time"
)

func counter(ch chan int) {
    for i := 0; i < 5; i++ {
        ch <- i // 将数据写入到 Channel 中
        fmt.Println("Sent:", i)
        time.Sleep(time.Second) // 休眠 1 秒钟
    }
    close(ch) // 关闭 Channel
}

func main() {
    ch := make(chan int) // 创建一个 int 类型的 Channel

    go counter(ch) // 启动一个 Goroutine 来执行计数器函数

    // 从 Channel 中读取数据，直到 Channel 被关闭
    for i := range ch {
        fmt.Println("Received:", i)
    }
}

Dalam contoh di atas, kami mencipta fungsi counter untuk menghantar 5 nombor dari 0 hingga 4 ke Saluran. Kemudian, dalam fungsi utama, kami menggunakan kata kunci julat untuk menerima data daripada Saluran dan mencetaknya. counter 函数，用于将 0 到 4 这 5 个数字发送到 Channel 中。然后，在 main 函数中，我们使用 range 关键字从 Channel 中接收数据，并打印出来。

注意，我们在 counter 函数中使用了 time.Sleep(time.Second)

Atas ialah kandungan terperinci Alat yang berkuasa untuk pengaturcaraan serentak di Golang: Saluran. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!