Cara menggunakan konteks untuk melaksanakan kawalan konkurensi permintaan dalam Go

Sebagai bahasa pengaturcaraan berprestasi tinggi, bahasa Go sentiasa cemerlang dalam keupayaan pengaturcaraan serentaknya. Untuk mengurus dan mengawal permintaan serentak dengan lebih baik, dalam bahasa Go, kami boleh menggunakan konteks untuk melaksanakan kawalan serentak permintaan. Artikel ini akan memperkenalkan cara menggunakan konteks untuk melaksanakan kawalan konkurensi permintaan dalam bahasa Go dan menunjukkannya melalui contoh kod.

Pengenalan kepada Konteks

Dalam bahasa Go, pakej konteks menyediakan cara untuk mengurus permintaan perlanggaran. Ia boleh menghantar data seluruh permintaan antara goroutine, termasuk tarikh akhir, tamat masa, isyarat pembatalan, dsb. Dengan menggunakan konteks, kami boleh mengurus dan mengawal permintaan serentak dengan lebih baik.

Langkah untuk menggunakan konteks untuk melaksanakan kawalan serentak permintaan

Berikut ialah langkah untuk menggunakan konteks untuk melaksanakan kawalan serentak permintaan:

1. Buat konteks akar: Pertama, kita perlu mencipta konteks akar. Konteks akar ialah konteks induk bagi semua konteks kanak-kanak. Kita boleh menggunakan context.TODO() atau context.Background() untuk mencipta konteks akar kosong. context.TODO()或context.Background()来创建一个空的根context。

ctx := context.TODO()

2. 创建子context：接下来，我们可以使用context.WithXXX()函数创建一个子context。这个函数接收一个父context作为参数，并返回一个新的子context。

childCtx := context.WithTimeout(ctx, time.Second*10)

在上述代码中，我们使用context.WithTimeout()函数创建了一个超时为10秒的子context。

3. 处理请求：在处理具体的请求时，我们可以使用context.Context类型的参数接收传递过来的context。在处理请求的过程中，我们可以使用context.Context的方法来获取context的相关信息。

func HandleRequest(ctx context.Context) {
    // 处理请求
}

4. 控制并发：在进行并发请求时，我们可以使用context.Context的Done()方法来判断请求是否被取消或超时。当调用Done()方法时，它会返回一个只读的Channel。如果请求被取消或超时，Done()方法会关闭这个Channel。

go func() {
    for {
        select {
        case <-ctx.Done():
            return
        default:
            // 发起请求
            HandleRequest(ctx)
        }
    }
}()

在上述代码中，我们使用for循环和select语句来监听context的Done()方法。当Done()方法返回时，我们就知道请求已经被取消或超时，可以退出循环。

5. 取消请求：在某些情况下，我们希望取消正在处理的请求。这时，我们可以调用context.CancelFunc类型的cancel()

cancel()

Buat subkonteks: Seterusnya, kita boleh menggunakan fungsi context.WithXXX() untuk mencipta subkonteks. Fungsi ini menerima konteks induk sebagai parameter dan mengembalikan konteks anak baharu.

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func Worker(ctx context.Context, wg *sync.WaitGroup) {
    defer wg.Done()
 
    for {
        select {
        case <-ctx.Done():
            // 请求已被取消或超时
            return
        default:
            // 处理请求
            fmt.Println("Handling request...")
            time.Sleep(time.Second * 1)
        }
    }
}

func main() {
    ctx := context.TODO()
    childCtx, cancel := context.WithTimeout(ctx, time.Second*5)
    defer cancel()

    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go Worker(childCtx, &wg)
    }

    wg.Wait()
    fmt.Println("All requests processed")
}

Dalam kod di atas, kami menggunakan fungsi context.WithTimeout() untuk mencipta subkonteks dengan tamat masa 10 saat.

Memproses permintaan: Apabila memproses permintaan tertentu, kami boleh menggunakan parameter jenis context.Context untuk menerima konteks yang diluluskan. Semasa proses memproses permintaan, kami boleh menggunakan kaedah context.Context untuk mendapatkan maklumat berkaitan konteks.

rrreee

Kawal konkurensi: Apabila membuat permintaan serentak, kita boleh menggunakan kaedah Done() context.Context untuk menentukan sama ada permintaan itu telah dibatalkan atau tamat masa . Apabila kaedah Done() dipanggil, ia mengembalikan Saluran baca sahaja. Jika permintaan dibatalkan atau tamat tempoh, kaedah Done() akan menutup Saluran.
rrreee

Dalam kod di atas, kami menggunakan pernyataan gelung for dan pilih untuk mendengar kaedah konteks Done(). Apabila kaedah Done() kembali, kami tahu bahawa permintaan telah dibatalkan atau tamat masa dan kami boleh keluar dari gelung.

🎜Batalkan Permintaan: Dalam sesetengah kes, kami ingin membatalkan permintaan yang sedang diproses. Pada masa ini, kami boleh memanggil kaedah cancel() jenis context.CancelFunc untuk membatalkan permintaan. 🎜🎜rrreee🎜Dalam kod di atas, kami memanggil kaedah cancel() untuk membatalkan permintaan. 🎜🎜Kod sampel🎜🎜Berikut ialah kod sampel ringkas yang menunjukkan cara menggunakan konteks untuk melaksanakan kawalan konkurensi permintaan. 🎜rrreee🎜Dalam kod di atas, kami mencipta konteks akar dan konteks kanak-kanak dengan tamat masa 5 saat. Kemudian, kami mencipta 5 goroutine untuk mengendalikan permintaan. Semasa proses memproses permintaan, kami menggunakan kaedah Done() konteks untuk menentukan sama ada permintaan itu dibatalkan atau tamat masa. Akhir sekali, kami menggunakan sync.WaitGroup untuk menunggu semua permintaan diproses. 🎜🎜Ringkasan🎜🎜Dengan menggunakan konteks, kami boleh mengurus dan mengawal permintaan serentak dengan lebih baik. Artikel ini memperkenalkan langkah untuk menggunakan konteks untuk melaksanakan kawalan konkurensi permintaan dan menunjukkannya melalui kod sampel. Saya percaya bahawa pembaca boleh memahami dan menggunakan konteks dengan lebih baik untuk mencapai kawalan serentak permintaan melalui pengenalan dan kod contoh artikel ini. 🎜

Atas ialah kandungan terperinci Cara menggunakan konteks untuk melaksanakan kawalan konkurensi permintaan dalam Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!