Comment arrêter la goroutine dans Golang

Dans Golang, la goroutine est l'unité de base de la programmation simultanée. Il s'agit d'une technologie de programmation asynchrone très puissante et couramment utilisée dans Golang. Cependant, pendant le développement réel, nous devrons peut-être arrêter une goroutine en cours d'exécution. Cet article explique comment arrêter la goroutine dans Golang.

Pourquoi devez-vous arrêter la goroutine

Dans la programmation simultanée, nous utilisons généralement la goroutine pour gérer les tâches. Ces tâches sont généralement indépendantes et n'interfèrent pas les unes avec les autres, et ne sont pas liées les unes aux autres. Parfois, nous devons arrêter certaines goroutines pendant l'exécution du programme afin de libérer des ressources, d'éviter de gaspiller des ressources CPU ou pour d'autres raisons. C'est le cas de l'arrêt de la goroutine au lieu d'attendre la fin de la goroutine.

Dans Golang, goroutine est un thread léger, et ils sont gérés par le planificateur. Le planificateur est responsable de l'allocation des goroutines aux cœurs de processeur disponibles pour l'exécution. Dans Golang, la technique courante pour arrêter la goroutine est implémentée via le canal. Nous verrons ensuite en détail comment utiliser le canal pour arrêter la goroutine.

Utilisez le canal pour arrêter la goroutine

Dans Golang, chaque goroutine a un identifiant unique et peut interagir avec le planificateur via l'identifiant. Vous pouvez utiliser un canal pour envoyer un message à une goroutine pour lui demander d'arrêter l'exécution. Normalement, nous utilisons un canal de type booléen comme canal d'arrêt pour contrôler le flux d'exécution de goroutine.

Pour montrer comment arrêter la goroutine, nous utilisons ci-dessous un exemple pour illustrer comment arrêter la goroutine dans Golang. Veuillez regarder le code suivant :

package main

import (
    "fmt"
    "time"
)

func worker(stopCh <-chan bool) {
    fmt.Println("Worker started.")
    for {
        select {
        case <-stopCh:
            fmt.Println("Worker stopped.")
            return
        default:
            fmt.Println("Working...")
            time.Sleep(1 * time.Second)
        }
    }
}

func main() {
    stopCh := make(chan bool)

    go worker(stopCh)

    time.Sleep(5 * time.Second)
    stopCh <- true

    time.Sleep(1 * time.Second)
    fmt.Println("Main stopped.")
}

Dans le code ci-dessus, nous définissons une fonction de travail pour effectuer des tâches, et définissons également un canal stopCh pour arrêter l'exécution de la fonction de travail. Dans la fonction principale, nous démarrons une goroutine pour exécuter la fonction de travail et envoyons un signal d'arrêt au canal stopCh après 5 secondes pour arrêter l'exécution de la fonction de travail.

Dans la fonction worker, nous utilisons l'instruction select pour écouter le canal stopCh. Une fois le signal d'arrêt reçu, nous quittons la boucle et arrêtons l'exécution. Dans la branche de cas par défaut, la fonction de travail exécutera en permanence "Working..." et tombera en état de veille. Cette boucle continuera jusqu'à ce que le canal stopCh reçoive un signal.

Résumé

Dans Golang, l'arrêt de la goroutine est obtenu en utilisant le canal. Nous pouvons utiliser un canal de type bool pour demander à goroutine d'arrêter l'exécution, et utiliser l'instruction select dans goroutine pour écouter le signal d'arrêt. Lorsqu'un signal d'arrêt est reçu, la goroutine quitte la boucle et arrête l'exécution. Grâce à cette méthode, nous pouvons bien contrôler le processus d'exécution de goroutine et éviter le gaspillage de ressources.

Ce qui précède explique comment implémenter l'arrêt goroutine dans Golang. Dans le développement réel, nous devons généralement coordonner les processus d'exécution de plusieurs goroutines et nous assurer qu'ils arrêtent l'exécution au bon moment. Par conséquent, il est très important de comprendre et de maîtriser la méthode d’arrêt de la goroutine.

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!