Traitement simultané des données dans Golang et Go WaitGroup-Golang-php.cn

Traitement simultané des données dans Golang et Go WaitGroup

PHPz

Libérer： 2023-09-28 15:09:41

original

691 Les gens l'ont consulté

Golang中的数据并发处理和Go WaitGroup

Traitement simultané des données et Go WaitGroup dans Golang

Introduction :
Dans le développement de logiciels modernes, le traitement simultané des données est une technologie très importante. Lors du traitement de grandes quantités de données, l’utilisation de techniques de concurrence peut améliorer considérablement les performances du programme et le temps de réponse. En tant que langage de programmation respectueux de la concurrence, Golang propose diverses façons de mettre en œuvre le traitement simultané des données, la plus couramment utilisée étant Go WaitGroup. Cet article présentera en détail le traitement de la simultanéité des données dans Golang et comment utiliser Go WaitGroup pour gérer les tâches simultanées.

Bases du traitement simultané
Dans Golang, la goroutine est principalement utilisée pour implémenter le traitement simultané. Goroutine est un thread léger qui peut s'exécuter simultanément avec d'autres goroutines. En utilisant des goroutines, plusieurs fonctions ou méthodes peuvent être exécutées simultanément dans le même programme, tirant pleinement parti de la puissance des processeurs multicœurs. Voici un exemple de code simple :

package main

import (
    "fmt"
    "time"
)

func main() {
    go printNumbers()
    go printLetters()
    time.Sleep(2 * time.Second)
}

func printNumbers() {
    for i := 1; i <= 5; i++ {
        fmt.Println(i)
        time.Sleep(500 * time.Millisecond)
    }
}

func printLetters() {
    for i := 'a'; i <= 'e'; i++ {
        fmt.Printf("%c
", i)
        time.Sleep(500 * time.Millisecond)
    }
}

Copier après la connexion

Dans le code ci-dessus, nous avons créé deux goroutines pour exécuter simultanément les fonctions printNumbers et printLetters. La fonction printNumbers imprime les chiffres de 1 à 5, et la fonction printLetters imprime les lettres minuscules a à e. En utilisant time.Sleep, le programme principal attend suffisamment longtemps pour s'assurer qu'il se termine une fois les deux goroutines terminées. printNumbers和printLetters函数。printNumbers函数打印数字1到5，printLetters函数打印小写字母a到e。通过使用time.Sleep让主程序等待足够长的时间，以确保两个goroutine完成后程序才退出。

Go WaitGroup使用
尽管通过time.Sleep等待goroutine完成是一种方式，但在实际开发中这种方法并不可靠和灵活。Golang提供了sync.WaitGroup来更好地管理goroutine的完成状态。WaitGroup是一个计数信号量，用于等待一组goroutine的完成。下面是使用WaitGroup的示例代码：

package main

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

func main() {
    var wg sync.WaitGroup
    wg.Add(2) // 添加两个任务

    go printNumbers(&wg)
    go printLetters(&wg)

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

func printNumbers(wg *sync.WaitGroup) {
    defer wg.Done() // 减少计数器

    for i := 1; i <= 5; i++ {
        fmt.Println(i)
        time.Sleep(500 * time.Millisecond)
    }
}

func printLetters(wg *sync.WaitGroup) {
    defer wg.Done() // 减少计数器

    for i := 'a'; i <= 'e'; i++ {
        fmt.Printf("%c
", i)
        time.Sleep(500 * time.Millisecond)
    }
}

Copier après la connexion

在上述代码中，我们首先创建了一个WaitGroup对象wg，并通过wg.Add(2)方法告知WaitGroup有两个任务需要等待。然后，我们分别在printNumbers和printLetters函数中调用wg.Done()方法，以减少计数器。最后，通过调用wg.Wait()方法，程序会一直阻塞，直到所有任务完成，然后继续执行后面的代码。

WaitGroup的高级用法
除了基本用法外，WaitGroup还提供了一些高级用法，例如限制并发数、超时控制等。下面是一个使用WaitGroup进行并发任务限制的示例代码：

package main

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

func main() {
    var (
        wg     sync.WaitGroup
        maxCon = 2 // 最大并发数
        tasks  = 10 // 总任务数
    )

    // 创建一个带有最大并发数限制的通道
    semaphore := make(chan struct{}, maxCon)

    for i := 0; i < tasks; i++ {
        wg.Add(1)
        go process(i, &wg, semaphore)
    }

    wg.Wait()
}

func process(id int, wg *sync.WaitGroup, semaphore chan struct{}) {
    defer wg.Done()

    semaphore <- struct{}{} // 每个任务开始前获取信号量
    defer func() {
        <-semaphore // 每个任务结束时释放信号量
    }()

    fmt.Printf("Task %d start
", id)
    time.Sleep(500 * time.Millisecond)
    fmt.Printf("Task %d finish
", id)
}

Copier après la connexion

在上述代码中，我们首先创建了一个semaphore通道，其容量为maxCon，即最大并发数。然后，我们通过循环为tasks个任务创建goroutine，每个goroutine开始前都会从semaphore通道获取一个信号量，表示还有可用的并发数。任务执行完毕后，会释放所占用的信号量。通过这种方式，我们可以限制并发数，避免同时执行过多goroutine而导致资源耗尽。

结语
本文介绍了Golang中如何实现数据并发处理以及使用WaitGroup来管理并发任务。通过使用goroutine和WaitGroup，我们可以轻松实现并发处理，充分发挥多核处理器的能力，并提高程序的性能。希望本文对您理解数据并发处理及WaitGroup

Bien qu'attendre que goroutine se termine pendant time.Sleep soit un moyen, cette méthode n'est pas fiable et flexible dans le développement réel. Golang fournit sync.WaitGroup pour mieux gérer l'état d'achèvement de goroutine. WaitGroup est un sémaphore de comptage utilisé pour attendre la fin d'un groupe de goroutines. Voici un exemple de code utilisant WaitGroup : 🎜🎜rrreee🎜Dans le code ci-dessus, nous créons d'abord un objet WaitGroup wg et passons wg.Add(2) indique à WaitGroup qu'il y a deux tâches à attendre. Ensuite, nous appelons la méthode wg.Done() respectivement dans les fonctions printNumbers et printLetters pour décrémenter le compteur. Enfin, en appelant la méthode wg.Wait(), le programme bloquera jusqu'à ce que toutes les tâches soient terminées, puis continuera à exécuter le code suivant. 🎜

WaitGroup

sémaphore

maxCon

tasks

semaphore

WaitGroup

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!