Exécution simultanée de tâches et Go WaitGroup dans Golang
Dans Golang, l'exécution simultanée de tâches est très importante. En exécutant des tâches simultanément, vous pouvez améliorer l'efficacité et la réactivité de votre programme. Golang fournit certaines fonctionnalités qui rendent l'exécution simultanée de tâches simple et efficace. L'une des fonctionnalités importantes est Go WaitGroup.
Go WaitGroup est une primitive de synchronisation dans Golang, utilisée pour attendre qu'un groupe de goroutines termine son exécution. Cela garantit que le code en attente ne se termine pas prématurément avant que toutes les coroutines n'aient fini de s'exécuter. Utilisez WaitGroup pour éviter la fin du programme avant la fin de l'exécution de la coroutine.
Ensuite, nous utiliserons un exemple spécifique pour démontrer l'exécution simultanée de tâches et l'utilisation de Go WaitGroup.
Tout d'abord, nous créons une fonction de tâche pour simuler certaines opérations chronophages. Cette fonction recevra un numéro de tâche en paramètre et imprimera le numéro de tâche et le message de fin d'exécution :
func simulateTask(taskNum int) { time.Sleep(time.Duration(rand.Intn(3)) * time.Second) fmt.Printf("Task %d is complete ", taskNum) }
Ensuite, nous créons une fonction principale, créons un groupe de tâches dans cette fonction et utilisons Go WaitGroup pour attendre pour tous Achèvement de la tâche :
func main() { var wg sync.WaitGroup // 创建一个WaitGroup tasks := 10 // 设定任务数量 for i := 0; i < tasks; i++ { wg.Add(1) // 增加WaitGroup的计数器 go func(taskNum int) { defer wg.Done() // 减少WaitGroup的计数器 simulateTask(taskNum) // 执行任务 }(i) } wg.Wait() // 等待所有任务完成 fmt.Println("All tasks are completed") }
Dans cet exemple, nous créons d'abord un objet WaitGroup puis définissons le nombre de tâches à exécuter. Dans la boucle de tâches, nous utilisons wg.Add(1) pour augmenter le compteur WaitGroup, indiquant qu'une tâche doit attendre d'être terminée. Nous avons ensuite créé une fonction anonyme en utilisant le mot-clé go où nous avons effectué la tâche réelle et avons appelé wg.Done() pour décrémenter le compteur du WaitGroup lorsque la tâche était terminée. Enfin, attendez que toutes les tâches soient terminées via l'instruction wg.Wait().
En exécutant ce programme, nous pouvons voir l'exécution simultanée des tâches et l'effet de Go WaitGroup. Chaque tâche attendra une période de temps aléatoire pour terminer son exécution et imprimera le message d'achèvement correspondant. Enfin, lorsque toutes les tâches sont terminées, le programme affiche le message « Toutes les tâches sont terminées ».
Cet exemple montre l'exécution simultanée de tâches dans Golang et l'utilisation de Go WaitGroup. En utilisant rationnellement les mécanismes de concurrence et d’attente, l’efficacité et les performances du programme peuvent être améliorées. Grâce aux puissantes fonctionnalités de concurrence de Golang, nous pouvons écrire des programmes simultanés efficaces et évolutifs.
Pour résumer, l'exécution de tâches simultanées et Go WaitGroup dans Golang sont des outils importants pour atteindre la concurrence. En utilisant correctement les mécanismes de concurrence, nous pouvons exploiter pleinement les capacités des processeurs multicœurs et améliorer les performances et la réactivité des programmes. Dans le même temps, grâce à la fonction d'attente de WaitGroup, nous pouvons garantir que le programme ne se terminera pas prématurément avant que toutes les tâches ne soient terminées. Go WaitGroup est un outil très utile pour les situations où vous devez effectuer un grand nombre de tâches et devez attendre qu'elles soient toutes terminées.
J'espère qu'à travers cet exemple, les lecteurs pourront comprendre les concepts de base et l'utilisation de l'exécution de tâches simultanées et de Go WaitGroup, et les appliquer de manière flexible dans des projets réels.
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!