Pourquoi mon canal Go Goroutine Timeout ne se déclenche-t-il jamais ?

Canal de délai d'attente Goroutine jamais invoqué

Lors de l'utilisation de goroutines et de canaux dans Go, il est essentiel de comprendre comment fonctionnent les délais d'attente. Dans cet extrait de code, le but est d'imprimer "TIMEOUT" au bout de 2 secondes si aucune valeur n'est reçue sur le canal c1. Cependant, le cas de délai d'attente n'est jamais exécuté.

Explication :

Le problème réside dans la façon dont le canal de délai d'attente est créé à l'intérieur de la boucle de sélection. Chaque fois qu'une valeur est reçue de c1, un nouveau canal de délai d'attente est créé en utilisant time.After(...). Cela annule effectivement le délai d'attente précédent et en démarre un nouveau. Tant que c1 continue de recevoir des valeurs, le canal de délai d'attente est constamment réinitialisé et n'atteint jamais son expiration de 2 secondes.

Solution :

Pour garantir que le délai d'attente est déclenché comme prévu, déplacez la création du canal de délai d'attente en dehors de la boucle de sélection. En le créant une seule fois, le canal reste actif jusqu'à son expiration, quelles que soient les valeurs reçues de c1.

Code modifié :

func main() {
    c1 := make(chan int, 1)
    timeout := time.After(2000 * time.Millisecond)

    go func() {
        for {
            time.Sleep(1500 * time.Millisecond)
            c1 <- 10
        }
    }()

    for {
        select {
        case i := <-c1:
            fmt.Println(i)
        case <-timeout:
            fmt.Println("TIMEOUT")
        }
    }

    fmt.Scanln()
}

Sortie :

10
10
10
...
TIMEOUT

Maintenant, après 2 secondes d'inactivité sur c1, "TIMEOUT" est correctement imprimé.

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!