Amalan dan prinsip terbaik kawalan konkurensi fungsi golang

Amalan terbaik untuk kawalan konkurensi dalam fungsi bahasa Go: Hadkan konkurensi: Gunakan mutex atau semaphore untuk mengelakkan perlumbaan data. Menggunakan saluran: Kawal komunikasi tak segerak antara fungsi melalui saluran. Gunakan kumpulan goroutine: pastikan sumber tidak dikeluarkan sehingga semua goroutine selesai. Pengendalian pengecualian: Mengendalikan pengecualian dengan selamat untuk mengelakkan penamatan yang tidak dijangka. Contoh praktikal: menggunakan kumpulan dan saluran goroutine untuk menanyakan pangkalan data secara selari sambil mengehadkan konkurensi dan mengendalikan pengecualian.

Amalan terbaik dan prinsip kawalan serentak fungsi dalam bahasa Go

Dalam bahasa Go, kawalan serentak fungsi adalah penting untuk mengurus fungsi yang dilaksanakan secara serentak. Di bawah disenaraikan beberapa amalan dan prinsip terbaik untuk membantu anda mengawal fungsi serentak dengan berkesan:

Hadkan serentak

• Gunakan sync.Mutex atau sync.RWMutex code> untuk mengehadkan serentak akses kepada sumber yang dikongsi dan mengelakkan persaingan data. <code>sync.Mutex 或 sync.RWMutex 来限制并发访问共享资源，避免数据竞争。
• 使用 Semaphore 或 RateLimiter 来调节并发函数的执行速率，防止系统超载。

使用通道

• 使用通道来控制函数之间的并发。通道提供了缓冲机制，使函数可以异步通信。
• 使用 select 语句来监控多个通道，以实现选择性等待或超时操作。

使用 goroutine 组

• 使用 sync.WaitGroup 或 context.Context
Gunakan Semaphore atau RateLimiter untuk melaraskan kadar pelaksanaan fungsi serentak untuk mengelakkan lebihan beban sistem.

Gunakan saluran

Gunakan saluran untuk mengawal keselarasan antara fungsi. Saluran menyediakan mekanisme penimbal yang membolehkan fungsi berkomunikasi secara tak segerak.
• Gunakan pernyataan select untuk memantau berbilang saluran bagi operasi tunggu terpilih atau tamat masa.

Menggunakan kumpulan goroutine

Gunakan sync.WaitGroup atau context.Context untuk menunggu kumpulan goroutine selesai.

Pastikan sumber yang dikongsi tidak dikeluarkan atau operasi kritikal dilakukan sebelum semua goroutine selesai.

package main

import (
    "context"
    "database/sql"
    "fmt"
    "sync"
)

func main() {
    db1 := connectToDB1()
    db2 := connectToDB2()

    var wg sync.WaitGroup
    resultCh := make(chan []string)

    wg.Add(2)
    go queryDB(db1, &wg, resultCh)
    go queryDB(db2, &wg, resultCh)

    go func() {
        // 等待 goroutine 完成并合并结果
        wg.Wait()
        close(resultCh)
    }()

    for results := range resultCh {
        fmt.Println(results)
    }
}

func queryDB(db *sql.DB, wg *sync.WaitGroup, resultCh chan<- []string) {
    defer wg.Done()
    rows, err := db.Query("SELECT * FROM table")
    if err != nil {
        log.Fatal(err)
    }
    var results []string
    for rows.Next() {
        var name string
        if err := rows.Scan(&name); err != nil {
            log.Fatal(err)
        }
        results = append(results, name)
    }
    rows.Close()
    resultCh <- results
}

Atas ialah kandungan terperinci Amalan dan prinsip terbaik kawalan konkurensi fungsi golang. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!