Bagaimana untuk mendapatkan data yang dikongsi dengan selamat dalam Goroutine?

Go boleh mendapatkan data kongsi goroutine dengan selamat melalui kaedah berikut: 1. Mutex (Mutex): membenarkan satu goroutine mempunyai akses eksklusif kepada data kongsi 2. Saluran (Saluran): menyelaraskan akses kepada data yang dikongsi dan berfungsi sebagai pautan antara goroutines Mekanisme pemindahan data; 3. Operasi Atom: membaca dan mengubah suai pembolehubah yang dikongsi secara atom untuk memastikan ketekalan data.

Bagaimana untuk mendapatkan data kongsi dengan selamat dalam goroutine dalam Go?

Dalam pengaturcaraan serentak, menyelaraskan akses kepada data yang dikongsi adalah penting. Bahasa Go menyediakan beberapa cara untuk mencapai ini, termasuk mutex, saluran dan operasi atom.

Mutex lock

Mutex digunakan untuk membenarkan satu goroutine mengakses data kongsi pada satu-satu masa. Untuk mencipta mutex, gunakan jenis sync.Mutex. Berikut ialah contoh cara menggunakan mutex: sync.Mutex 类型。以下是如何使用互斥锁示例：

package main

import (
    "fmt"
    "sync"
)

// 共享变量
var counter int

func main() {
    var mu sync.Mutex

    // 创建 10 个 goroutine，每个 goroutine 增加 counter
    for i := 0; i < 10; i++ {
        go func() {
            mu.Lock()
            defer mu.Unlock()
            counter++
            fmt.Printf("goroutine %d: %d\n", i, counter)
        }()
    }
}

通道

通道可以用来在 goroutine 之间传递数据，也可以用来协调对共享数据的访问。要创建通道，可以使用 make(chan) 函数。以下是如何使用通道示例：

package main

import (
    "fmt"
    "sync"
)

// 共享变量
var counter int

func main() {
    ch := make(chan struct{})

    // 创建 10 个 goroutine，每个 goroutine 增加 counter
    for i := 0; i < 10; i++ {
        go func() {
            defer close(ch)

            for {
                select {
                case <-ch:
                    return
                default:
                    counter++
                    fmt.Printf("goroutine %d: %d\n", i, counter)
                }
            }
        }()
    }

    // 等待所有 goroutine 完成
    for i := 0; i < 10; i++ {
        <-ch
    }
}

原子操作

原子操作可以用来原子性地读取和修改共享变量的值。Go 语言提供了 sync/atomic

package main

import (
    "fmt"
    "sync/atomic"
)

// 共享变量
var counter int

func main() {
    // 使用 AddInt64 增加 counter
    for i := 0; i < 10; i++ {
        go func() {
            atomic.AddInt64(&counter, 1)
            fmt.Printf("goroutine %d: %d\n", i, counter)
        }()
    }
}

Saluran

🎜🎜Saluran boleh digunakan untuk menghantar data antara goroutine dan juga boleh digunakan untuk menyelaraskan akses kepada data yang dikongsi. Untuk membuat saluran, gunakan fungsi make(chan). Berikut ialah contoh cara menggunakan saluran: 🎜rrreee🎜🎜Operasi atom🎜🎜🎜Operasi atom boleh digunakan untuk membaca secara atom dan mengubah suai nilai pembolehubah yang dikongsi. Bahasa Go menyediakan pakej sync/atomic untuk menyokong operasi atom. Berikut ialah contoh cara menggunakan operasi atom: 🎜rrreee🎜 Antara kaedah ini, kaedah yang manakah untuk dipilih bergantung pada senario tertentu dan tahap jaminan keselamatan yang diperlukan. 🎜

Atas ialah kandungan terperinci Bagaimana untuk mendapatkan data yang dikongsi dengan selamat dalam Goroutine?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!