Allez plus loin : démonstrations pratiques de code de programmation simultanée

Langage Go approfondi : démonstration pratique de code de programmation simultanée

À l'ère d'Internet d'aujourd'hui, la programmation simultanée est devenue une technologie indispensable et importante dans le développement de logiciels. En tant que langage de programmation offrant des performances de concurrence supérieures, le langage Go fournit des fonctionnalités de programmation simultanée riches et puissantes, permettant aux développeurs d'écrire plus facilement des programmes simultanés efficaces. Cet article utilisera des exemples de code pratiques pour montrer comment utiliser la programmation simultanée dans le langage Go pour améliorer les performances et l'efficacité du programme.

1. Bases de la concurrence

Dans le langage Go, nous pouvons utiliser la goroutine pour réaliser une exécution simultanée. Les goroutines sont similaires aux threads, mais sont plus légères que les threads. Un programme Go peut exécuter des milliers de goroutines en même temps. Ce qui suit est un exemple de goroutine simple :

package main

import (
    "fmt"
    "time"
)

func sayHello() {
    for i := 0; i < 5; i++ {
        fmt.Println("Hello")
        time.Sleep(100 * time.Millisecond)
    }
}

func main() {
    go sayHello()
    time.Sleep(500 * time.Millisecond)
    fmt.Println("Main function")
}

Dans le code ci-dessus, nous utilisons le mot-clé go pour démarrer une goroutine afin d'exécuter la fonction sayHello et la fonction principale < code> main est également en cours d'exécution. Grâce à goroutine, nous pouvons exécuter différentes tâches simultanément et améliorer les performances du programme. go关键字启动了一个goroutine来执行sayHello函数，同时主函数main也在执行。通过goroutine，我们可以实现并发执行不同的任务，提高程序的性能。

2. 并发通信

在并发编程中，通信是关键的一环。Go语言提供了channel来实现goroutine之间的通信。下面是一个使用channel进行通信的示例：

package main

import (
    "fmt"
)

func produce(ch chan int) {
    for i := 0; i < 5; i++ {
        ch <- i
    }
    close(ch)
}

func consume(ch chan int) {
    for num := range ch {
        fmt.Println("Consumed:", num)
    }
}

func main() {
    ch := make(chan int)
    go produce(ch)
    go consume(ch)
    fmt.Scanln()
}

上面的代码中，我们定义了一个channel用于生产者和消费者之间的通信。生产者将数据写入channel，消费者从channel中读取数据并进行处理。通过channel可以实现goroutine之间的安全通信，避免竞争条件的发生。

3. 并发控制

在实际开发中，我们可能需要控制goroutine的执行顺序或者数量。Go语言提供了sync包中的WaitGroup和Mutex等工具来实现并发控制。下面是一个使用WaitGroup实现并发控制的示例：

package main

import (
    "fmt"
    "sync"
)

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Worker %d starting
", id)
    fmt.Printf("Worker %d done
", id)
}

func main() {
    var wg sync.WaitGroup
    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go worker(i, &wg)
    }
    wg.Wait()
    fmt.Println("All workers done")
}

在上面的代码中，我们使用WaitGroup来等待所有goroutine执行完毕。通过Add方法增加等待的goroutine数量，Done方法表示一个goroutine执行完毕。通过Wait

rrreee

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!