Comment synchroniser la génération de nombres aléatoires dans le traitement parallèle Golang ?

Génération de nombres aléatoires synchronisée dans la programmation simultanée Go : utilisez un mutex (sync.Mutex) pour contrôler l'accès au générateur de nombres aléatoires rand.Rand. Chaque goroutine acquiert le mutex avant de générer un nombre aléatoire et libère le mutex après l'avoir généré. Cela garantit qu’un seul goroutine à la fois peut accéder au générateur de nombres aléatoires, éliminant ainsi les courses aux données.

Comment synchroniser la génération de nombres aléatoires dans le traitement parallèle Golang ?

Dans la programmation simultanée Go, il est parfois nécessaire de générer des nombres aléatoires sur plusieurs goroutines. Si la synchronisation n'est pas prise en compte, cela peut conduire à des conditions de concurrence et à un comportement imprévisible.

Génération de nombres aléatoires parallèles

Go fournit un package math/rand pour générer des nombres pseudo-aléatoires. Par défaut, il fonctionne de manière non sécurisée en matière de concurrence. Cela signifie que si la même instance rand.Rand est accédée simultanément, des courses de données et des résultats indéterminés se produiront. math/rand 包来生成伪随机数。默认情况下，它以非并发安全的方式操作。这意味着如果并发访问同一个 rand.Rand 实例，则会出现数据争用和不确定的结果。

使用互斥锁进行同步

为了在并行处理中同步随机数生成，可以使用互斥锁 (sync.Mutex)。互斥锁允许一次只有一个 goroutine 访问临界区（在这种情况下，rand.Rand 实例）。

以下代码演示如何使用互斥锁同步随机数生成：

package main

import (
    "math/rand"
    "sync"
)

var (
    // 全局互斥锁
    randomLock sync.Mutex
    
    // 全局随机数生成器
    randomGen *rand.Rand
)

func init() {
    // 在程序启动时初始化随机数生成器
    // 并设置随机种子
    randomGen = rand.New(rand.NewSource(time.Now().UnixNano()))
}

func main() {
    // 创建一个等待组来跟踪 goroutine
    var wg sync.WaitGroup
    
    // 启动 10 个 goroutine 生成 10 个随机数
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(i int) {
            // 使用互斥锁保护随机数生成
            randomLock.Lock()
            value := randomGen.Intn(100)
            randomLock.Unlock()
            
            // 打印生成的随机数
            fmt.Printf("Goroutine %d: %d\n", i, value)
            wg.Done()
        }(i)
    }

    // 等待所有 goroutine 完成
    wg.Wait()
}

在这种方法中，使用了一个全局 randomLock 互斥锁来保护对 randomGen

Synchronisation à l'aide de mutex

Pour synchroniser la génération de nombres aléatoires dans un traitement parallèle, vous pouvez utiliser des verrous mutex (sync.Mutex). Un mutex permet à une seule goroutine d'accéder à la section critique à la fois (dans ce cas, l'instance rand.Rand). 🎜🎜Le code suivant montre comment utiliser un mutex pour synchroniser la génération de nombres aléatoires : 🎜rrreee🎜Dans cette approche, un mutex global randomLock est utilisé pour protéger l'accès à randomGen au générateur de nombres aléatoires. Chaque goroutine acquiert le mutex avant de générer un nombre aléatoire et libère le mutex après l'avoir généré. Cela garantit qu’un seul goroutine à la fois a accès au générateur de nombres aléatoires, éliminant ainsi les courses aux données. 🎜🎜De cette manière, des nombres aléatoires peuvent être générés de manière sûre et fiable lors d'un traitement parallèle. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!