Nombre d'éléments dans un canal

À l'aide d'un tampon de canal, comment mesurer la façon dont de nombreux éléments sont dans le canal? Par exemple, je suis de la création et de l'envoi sur un canal comme ceci:

send_ch := make(chan []byte, 100)
//code
send_ch <- msg

Je veux mesurer combien msgs sont dans le canal send_ch.

Je suis conscient qu'en raison de la simultanéité de la mesure ne sera pas exact, comme le droit de préemption pourrait survenir entre la mesure et de l'action (par exemple discuté dans cette vidéo Google I/O 2012 - Aller Modes D'Accès Concurrentiel). Je vais utiliser cette pour le contrôle de flux entre les producteurs et les consommateurs ie une fois que j'ai passé à travers une ligne des hautes eaux, la modification de certains comportements jusqu'à ce que je passe en retrait au moyen d'une faible filigrane.

InformationsquelleAutor Sonia Hamilton | 2012-10-22
  1. 120

    http://golang.org/pkg/builtin/#len

    func len(Type v) int

    Le len intégré dans la fonction retourne la longueur de v, en fonction de son type:

    • Tableau: le nombre d'éléments de c.
    • Pointeur de tableau: le nombre d'éléments dans *v (même si v est nul).
    • Une tranche ou d'une carte: le nombre d'éléments de v, si v est nul, len(v) est égale à zéro.
    • Chaîne: le nombre d'octets dans la v.
    • Canal: le nombre d'éléments mis en file d'attente (non lus) dans le canal de la mémoire tampon; si v est nul, len(v) est égale à zéro.
    package main

import "fmt"

func main() {
        c := make(chan int, 100)
        for i := 0; i < 34; i++ {
                c <- 0
        }
        fmt.Println(len(c))
}

    sera de sortie:

    34
    • Grâce Artem. C'est une liste non-utilisation de len - je me serais attendu le retour de la capacité d'un canal, pas le nombre d'éléments dans la! Bon à savoir, merci encore.
    • Si vous l'aurait voulu la capacité, le construit en fonction de cap le ferait.
    • Ce que je trouve intéressant ici, c'est que si le canal est fait sans une capacité(c := make(chan int)) vous ne pouvez pas obtenir la longueur. Je n'ai pas encore trouvé une raison à cela. Oui, c'est la capacité renvoie à 0 ainsi
    • Je me sens bizarre que quand c'est non, je ne peux pas obtenir de sa longueur. Et lors de l'utilisation de goroutines, ça bousille.
    • et Berkant, Si le canal est sans tampon (capacité=0), la longueur sera de zéro. L'expéditeur des blocs jusqu'à ce que le destinataire a bien reçu la valeur. golang.org/doc/effective_go.html#channels
    InformationsquelleAutor Artem Shitov