Liczba elementów w kanale

Jak mierzyć liczbę elementów w kanale za pomocą kanału buforowanego? Na przykład tworzę i wysyłam na takim kanale:

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

Chcę zmierzyć ile wiad są w kanale send_ch .

Zdaję sobie sprawę, że ze względu na współbieżność pomiar nie będzie dokładny, ponieważ między pomiarem a działaniem może wystąpić wywłaszczanie (np. Omówione w tym filmie Google I / O 2012 - Go Concurrency Patterns ). Użyję tego do kontroli przepływu między producentami a konsumentami, tj. Gdy przejdę przez wysoki znak wodny, zmieniając pewne zachowanie, aż przejdę z powrotem przez niski znak wodny.

— Sonia Hamilton
źródło

150

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

func len (v Type) int
Funkcja wbudowana len zwraca długość v, zgodnie z jej typem:

Tablica: liczba elementów w v.

Wskaźnik do tablicy: liczba elementów w * v (nawet jeśli v jest zerowe).

Slice lub map: liczba elementów w v; jeśli v jest zerowe, len (v) jest równe zero.

Ciąg: liczba bajtów w v.

Kanał: liczba elementów w kolejce (nieprzeczytanych) w buforze kanału; jeśli v jest zerowe, len (v) jest równe zero.

package main

import "fmt"

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

wyświetli:

— Artem Shitov
źródło

Dzięki Artem. To nieoczekiwane użycie len - spodziewałem się, że zwróci pojemność kanału, a nie liczbę jego elementów! Dobrze wiedzieć, jeszcze raz dziękuję.

— Sonia Hamilton,

Gdybyś chciał mieć taką pojemność, capzrobiłaby to wbudowana funkcja .

— ANisus

To, co uważam za interesujące, to fakt, że jeśli kanał jest wykonany bez pojemności ( c := make(chan int)), nie można uzyskać jego długości. Nie znalazłem powodu. Tak, jego pojemność również wraca jako 0

— Brettski

Dziwnie się czuję, że kiedy jest niebuforowany, nie mogę uzyskać jego długości. A kiedy używasz goroutines, to trochę psuje.

— Berkant Ipek

@Brettski i Berkant, Jeśli kanał jest niebuforowany (pojemność = 0), długość zawsze będzie wynosić zero. Nadawca blokuje się, dopóki odbiorca nie otrzyma wartości. golang.org/doc/effective_go.html#channels

— Farshid T