Comment les opérations de canal chaîné dans l'instruction « select » de Go affectent-elles le comportement de blocage et de non-blocage ?

Opérations de canal chaîné dans un cas de sélection : comprendre les comportements bloquants et non bloquants

Dans le modèle de concurrence de Go, select est une construction puissante qui permet aux goroutines d'attendre plusieurs canaux simultanément. Cependant, un piège courant survient lorsque l'on tente d'enchaîner les opérations de canal dans un cas sélectionné, car cela peut conduire à un comportement inattendu et à des blocages potentiels.

Considérez l'extrait de code suivant, qui tente de multiplexer deux canaux (A et B ) avec différents délais temporisés à l'aide de select :

func main() {
    ch := fanIn(talk("A", 10), talk("B", 1000))

    for i := 0; i < 10; i++ {
        fmt.Printf("%q\n", <-ch)
    }
}

Dans cet exemple, talk renvoie un canal qui envoie une séquence de messages avec un délai spécifié. fanIn est une fonction d'assistance qui crée un nouveau canal qui reçoit les valeurs de input1 et input2 à l'aide d'une instruction select.

Lorsque l'instruction select case est modifiée comme suit :

select {
    case ch <- <-input1:
    case ch <- <-input2:
}

une un résultat inattendu se produit. Certaines valeurs sont supprimées et, finalement, un blocage se produit car plus aucune valeur n'est reçue par le canal fan-in.

Pour comprendre ce comportement, il est crucial de saisir le concept d'opérations bloquantes et non bloquantes dans sélectionner. Dans une instruction select, une seule opération de lecture ou d'écriture de canal est non bloquante à un moment donné. Toutes les autres opérations se comportent normalement.

Dans le cas de sélection modifié, les opérations de réception de canal (<-input1 et <-input2) sont non bloquantes. Cela signifie qu'ils reviennent immédiatement, même s'il n'y a aucune valeur à recevoir.

La conséquence de ce comportement non bloquant est que lorsque la première opération de réception réussit (par exemple, depuis <-input1), elle lit et stocke la valeur. Cependant, l'opération ch <- suivante peut toujours être bloquée même si elle n'est pas bloquante. Ce blocage se produit car la boucle de fonction principale n'a pas encore consommé la valeur du canal combiné.

En conséquence, les valeurs sont supprimées, conduisant à l'impasse observée.

Pour un comportement correct, assurez-vous que seule l'opération finale d'envoi ou de réception dans un cas sélectionné est non bloquante. En d'autres termes, utilisez l'opérateur d'affectation := au lieu de l'opérateur fléché <- pour les opérations de réception intermédiaires.

select {
    case t := <-input1:
        ch <- t
    case t := <-input2:
        ch <- t
}

En ajustant le cas de sélection de cette façon, les opérations de canal sont correctement chaînées et toutes les valeurs sont correctement envoyés et reçus sans risque de perte de valeurs ou de blocages.

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!