Chiudere un channel serve ad indicare che non verranno più inviati su quel channel. Questo è utile per comunicare il completamento di un operazione a chi sta ascoltando sul channel. |
|
package main
|
|
import "fmt"
|
|
In questo esempio useremo un channel |
func main() {
jobs := make(chan int, 5)
done := make(chan bool)
|
Questa è la goroutine worker, che riceverà i task
in modo continuativo dal channel |
go func() {
for {
j, more := <-jobs
if more {
fmt.Println("received job", j)
} else {
fmt.Println("received all jobs")
done <- true
return
}
}
}()
|
Questo invia 3 job alla goroutine worker sul channel
|
for j := 1; j <= 3; j++ {
jobs <- j
fmt.Println("sent job", j)
}
close(jobs)
fmt.Println("sent all jobs")
|
Attendiamo la goroutine worker utilizzando l’approccio di sincronizzazione che abbiamo visto negli esempi precedenti |
<-done
}
|
$ go run closing-channels.go
sent job 1
received job 1
sent job 2
received job 2
sent job 3
received job 3
sent all jobs
received all jobs
|
|
L’esempio che segue deriva direttamente dal concetto di
chiusura di un channel: come effettuare un |
Prossimo esempio: Range sui Channel.