Maison > Article > développement back-end > Secrets de programmation simultanée Golang : comment utiliser correctement les Goroutines
Les secrets de la programmation simultanée Golang : Comment utiliser correctement Goroutines
Introduction :
Dans le domaine du développement logiciel d'aujourd'hui, les hautes performances et la haute concurrence sont des défis auxquels chaque développeur doit faire face. En tant que langage de programmation simultanée efficace, Golang fournit des outils et des bibliothèques puissants pour gérer les tâches simultanées. L'un des concepts les plus importants est celui des Goroutines, qui nous permettent d'implémenter facilement des modèles de programmation à haute concurrence. Cet article vous guidera sur la façon d'utiliser correctement Goroutines et d'éviter les pièges et les erreurs courants.
1. Que sont les Goroutines ?
Les Goroutines sont l'un des concepts fondamentaux du modèle de concurrence de Golang, qui peut exécuter des tâches en parallèle dans différentes fonctions. Contrairement aux threads traditionnels, les Goroutines sont gérées par le planificateur de Golang, ce qui les rend très efficaces, des milliers de Goroutines peuvent être facilement créées et la surcharge liée à leur commutation est très faible. Voici un exemple simple montrant comment créer et démarrer une Goroutine :
func main() { go printHello() fmt.Println("Main function") } func printHello() { fmt.Println("Hello Goroutine!") }
Dans le code ci-dessus, nous utilisons le mot-clé go
pour la démarrer avant la fonction printHello
. Une Goroutine , et "Main function"
est imprimé dans la fonction main
. Lorsque nous exécutons ce code, il affiche à la fois "Bonjour Goroutine!"
et "Fonction principale"
. go
在printHello
函数前启动了一个Goroutine,并且在main
函数中打印了"Main function"
。当我们运行这段代码时,它会同时打印出"Hello Goroutine!"
和"Main function"
。
二、避免Goroutine泄露
使用Goroutines的一个常见错误是未正确管理它们的生命周期,导致它们不会结束或回收。这可能会导致内存泄漏和资源浪费,并最终导致程序崩溃。为了避免Goroutine泄漏,我们可以使用sync.WaitGroup
来等待Goroutines完成。
func main() { var wg sync.WaitGroup wg.Add(1) go printHello(&wg) wg.Wait() } func printHello(wg *sync.WaitGroup) { defer wg.Done() fmt.Println("Hello Goroutine!") }
在上面的代码中,我们创建了一个sync.WaitGroup
变量,并在main
函数中调用了Add
方法来指定要等待的Goroutines数量。在printHello
函数中,我们使用defer
关键字在函数结束时调用Done
方法,以通知WaitGroup
已完成。最后,在main
函数中调用Wait
方法来等待所有的Goroutines完成。
三、避免数据竞争
在并发编程中,数据竞争是一个常见的问题。当多个Goroutines同时访问和修改共享变量时,可能会导致未定义的行为和Bug。为了避免数据竞争,我们可以使用互斥锁(Mutex)来限制对共享资源的访问。
var counter int var mutex sync.Mutex func main() { var wg sync.WaitGroup wg.Add(2) go increment(&wg) go increment(&wg) wg.Wait() fmt.Println("Counter:", counter) } func increment(wg *sync.WaitGroup) { defer wg.Done() for i := 0; i < 1000000; i++ { mutex.Lock() counter++ mutex.Unlock() } }
在上面的代码中,我们创建了一个全局变量counter
用于共享计数,并且使用互斥锁mutex
来确保每次访问和修改counter
时只有一个Goroutine。我们通过调用Lock
方法来获取互斥锁,执行完操作后再调用Unlock
Une erreur courante lors de l'utilisation de Goroutines est de ne pas gérer correctement leur cycle de vie, ce qui entraîne leur non-fin ou leur recyclage. Cela peut entraîner des fuites de mémoire et un gaspillage de ressources, et finalement provoquer le blocage du programme. Pour éviter les fuites de Goroutine, nous pouvons utiliser sync.WaitGroup
pour attendre la fin de Goroutines.
rrreee
sync.WaitGroup
et appelé la méthode Add
dans la fonction main
pour spécifier le nombre de Goroutines attendre. Dans la fonction printHello
, nous utilisons le mot-clé defer
pour appeler la méthode Done
à la fin de la fonction pour notifier WaitGroup code> qu'il a Terminé. Enfin, appelez la méthode <code>Wait
dans la fonction main
pour attendre la fin de toutes les Goroutines. 3. Évitez la concurrence entre les donnéescounter
pour le nombre partagé, et utilisé un verrou mutex mutex
pour garantir que chaque accès et modification counter n'a qu'un seul Goroutine. Nous obtenons le verrou mutex en appelant la méthode <code>Lock
, puis appelons la méthode Unlock
pour libérer le verrou mutex une fois l'opération terminée. 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!