Anzahl der Elemente in einem Kanal

Question

Wie können Sie mit einem gepufferten Kanal messen, wie viele Elemente sich im Kanal befinden? Zum Beispiel, ich bin zu schaffen und auf einem Kanal wie folgt gesendet:

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

ich messen will, wie viele msgs im Kanal send_ch sind.

Ich bin mir bewusst, dass die Messung aufgrund der Parallelität nicht genau sein wird, da eine Vorbelegung zwischen Messung und Aktion auftreten könnte (zB in diesem Video beschrieben Google I/O 2012 - Go Concurrency Patterns). Ich werde das für die Flusskontrolle zwischen Produzenten und Konsumenten verwenden, dh sobald ich ein High Watermark passiert habe, etwas Verhalten ändern, bis ich durch ein niedriges Wasserzeichen zurückgehe.

Answer 1

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

func len (v Type) int
LEN eingebaute Funktion, die Länge von v liefert, je nach Typ:

• Array: die Anzahl der Elemente in v.
• Zeiger auf Array: die Anzahl der Elemente in * v (auch wenn v ist Null).
• Slice oder Map: die Anzahl der Elemente in v; Wenn v Null ist, ist len ​​(v) Null.
• Zeichenfolge: die Anzahl der Bytes in v.
• Kanal: Die Anzahl der Elemente in der Warteschlange (ungelesen) im Kanalpuffer; Wenn v Null ist, ist len ​​(v) Null.

package main 

import "fmt" 

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

AUSGABE:

34