select ignored slow case?

Question

Ich verwende einen solchen select auf mehreren Fällen:

for { 
    select { 
    case data:= <- highFreqChan: 
     // do something: 
    case <- time.After(time.Second * 5): 
     // send some heartbeat like data... 
    } 
} 

Ich finde, dass, wenn highFreqChan riesige Daten bekam, wird nicht der Herzschlag Fall eintreten, und wenn Stoppdaten highFreqChan, den Herzschlag Fall wieder lebendig Senden , wie man es immer den Herzschlagfall eingibt, während das highFreqChan immer noch arbeitet?

Answer 1

Sie laufen time.After als Teil der Select-Bedingung, was bedeutet, dass es zum Zeitpunkt der Auswahl ausgewertet wird ... was bedeutet, dass es 5 Sekunden abläuft, nachdem die Auswahl erreicht ist. Sie werden diesen Fall nur eingeben, wenn highFreqChan 5 Sekunden lang keine Daten enthält.

Wenn Sie etwas alle 5 Sekunden tun möchten, verwenden Sie eine time.Ticker statt, etwa so:

heartbeat := time.NewTicker(5 * time.Second) 
defer heartbeat.Stop() 
for { 
    select { 
    case data:= <- highFreqChan: 
     // do something: 
    case <- heartbeat.C: 
     // send some heartbeat like data... 
    } 
}