Comment pouvons-nous utiliser des canaux dans Go à la place de mutex?

Question

Les canaux combinent la communication - l'échange d'une valeur - avec la synchronisation - garantissant que deux calculs (goroutines) sont dans un état connu.

Comment est-il possible d'utiliser les canaux de Google Go pour exécuter les fonctionnalités de mutex?

package main 

import "sync" 

var global int = 0 
var m sync.Mutex 

func thread1(){ 
    m.Lock() 
    global = 1 
    m.Unlock() 
} 

func thread2(){ 
    m.Lock() 
    global = 2 
    m.Unlock() 
} 

func main(){ 
    go thread1() 
    go thread2() 
} 

Answer 1

Un exemple d'utilisation d'un canal comme Mutex:

package main 

var global int = 0 
var c = make(chan int, 1) 

func thread1(){ 
    <-c // Grab the ticket 
    global = 1 
    c <- 1 // Give it back 
} 

func thread2(){ 
    <-c 
    global = 2 
    c <- 1 
} 

func main() { 
    c <- 1 // Put the initial value into the channel 
    go thread1() 
    go thread2() 
} 

Answer 2

Si vous avez un canal c que vous initialisez avec 1 pièce, alors vous pouvez « vérifier » la « mutex » en supprimant la valeur du canal (<-c). Vous pouvez le "libérer" en ajoutant la valeur en retour (c <- 1). Puisque l'opérateur a) est atomique, et b) bloque jusqu'à ce qu'il y ait quelque chose à extraire, il fonctionne comme un mutex, puisque si un thread d'exécution a déjà été extrait, il n'y aura rien le canal, et donc il va bloquer jusqu'à ce que le thread qui l'a fait sortir renvoie une valeur au canal pour un autre thread à extraire.