Bagaimana untuk melaksanakan corak pengeluar-pengguna menggunakan fungsi serentak dalam bahasa Go?

Bagaimana untuk melaksanakan corak pengeluar-pengguna menggunakan fungsi serentak dalam bahasa Go?

Dalam sains komputer, corak pengeluar-pengguna ialah corak reka bentuk konkurensi klasik. Ia melibatkan dua peranan utama: pengeluar bertanggungjawab untuk menjana data, dan pengguna bertanggungjawab untuk memproses data ini. Pengeluar dan pengguna berinteraksi melalui penimbal yang dikongsi Pengeluar meletakkan data ke dalam penimbal, dan pengguna mengeluarkan data daripada penimbal untuk diproses.

Dalam bahasa Go, kita boleh melaksanakan model pengeluar-pengguna melalui fungsi dan saluran serentak. Di bawah ialah contoh kod yang menunjukkan cara melaksanakan corak ini menggunakan bahasa Go.

package main

import (
    "fmt"
    "math/rand"
    "sync"
    "time"
)

// 缓冲区大小
const bufferSize = 5

// 生产者函数
func producer(buffer chan<- int, wg *sync.WaitGroup) {
    defer wg.Done()

    for i := 0; i < 10; i++ {
        value := rand.Intn(100) // 生成一个随机数作为数据
        buffer <- value        // 将数据放入缓冲区
        fmt.Println("Producer produces", value)
        time.Sleep(time.Millisecond * time.Duration(rand.Intn(500)))
    }

    close(buffer) // 关闭缓冲区
}

// 消费者函数
func consumer(buffer <-chan int, wg *sync.WaitGroup) {
    defer wg.Done()

    for value := range buffer {
        fmt.Println("Consumer consumes", value)
        time.Sleep(time.Millisecond * time.Duration(rand.Intn(1000)))
    }
}

func main() {
    buffer := make(chan int, bufferSize)
    var wg sync.WaitGroup

    wg.Add(2)

    go producer(buffer, &wg)
    go consumer(buffer, &wg)

    wg.Wait()
}

Dalam kod di atas, kami mentakrifkan penimbal buffer，大小为 5。生产者函数 producer 生成随机数作为数据，并放入缓冲区中。消费者函数 consumer 从缓冲区中取出数据并进行处理。主函数使用 sync.WaitGroup untuk memastikan program tidak akan keluar sehingga fungsi pengeluar dan pengguna dilaksanakan.

Dengan menjalankan kod di atas, kita dapat melihat bahawa pengeluar terus menjana data dan memasukkannya ke dalam penimbal, manakala pengguna secara berterusan mengeluarkan data daripada penimbal untuk diproses. Oleh kerana saiz penimbal ialah 5, apabila penimbal penuh, pengeluar akan menyekat sehingga ada lokasi percuma. Begitu juga, apabila penimbal kosong, pengguna akan menyekat sehingga data tersedia.

Untuk meringkaskan, menggunakan fungsi dan saluran serentak dalam bahasa Go, kami boleh melaksanakan corak pengeluar-pengguna dengan mudah. Model ini membolehkan pengeluar dan pengguna bekerja secara serentak, meningkatkan daya pengeluaran dan responsif sistem. Dengan menetapkan saiz penimbal dengan sewajarnya, kami boleh mengawal kelajuan pengeluar dan pengguna untuk menyesuaikan diri dengan keperluan senario yang berbeza.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan corak pengeluar-pengguna menggunakan fungsi serentak dalam bahasa Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!