Nell’articolo precedente abbiamo illustrato un primo meccanismo per notificare al ricevente la chiusura del channel, ovvero l’invio di una stringa dedicata che comunica la fine del flusso. Go mette a disposizione la funzione close con cui esplicitare che il canale \u00e8 stato chiuso, la chiusura non \u00e8 una operazione obbligatoria come nel caso dei file, ma permette di notificare al ricevente in modo esplicito la chiusura dello stream di dati.<\/p>\n\n\n\n
func workerCloser(channel chan string) {\n\tchannel <- \"workerCloser\"\n\tclose(channel)\n}\nmain() {\n\tcanale4 := make(chan string)\n\tgo workerCloser(canale4)\n\tmsg3, ok := <-canale4\n\tfmt.Println(msg3)\n\tmsg3, ok = <-canale4\n\tif !ok {\n\t\tfmt.Println(\"Canale chiuso\")\n\t}\n}<\/pre>\n\n\n\nNell’esempio ho realizzato una funzione che scrive un messaggio e successivamente chiude il canale. Per capire se il canale \u00e8 stato chiuso o meno leggo il secondo parametro ok di tipo boolean che vale false qualora il canale sia stato chiuso esplicitamente.<\/p>\n\n\n\n
Insieme al close go mette a disposizione range, che avevamo visto usato per scorrere gli slices e che applicato ai channel permette di leggere tutti i valori nel channel fino alla chiusura.<\/p>\n\n\n\n
func contatore(channel chan int, max int) {\n\tfor i := 0; i < max; i++ {\n\t\tchannel <- i\n\t}\n\tclose(channel)\n}\nmain() {\n\tcanale5 := make(chan int, 10)\n\tgo contatore(canale5, 5)\n\tfor valore := range canale5 {\n\t\tfmt.Println(valore)\n\t}\n}<\/pre>\n\n\n\nNell’esempio ho creato una funzione contatore che riceve un parametro in ingresso e tramite ciclo for invia i parametri sul channel. Terminato il ciclo chiude il channel con il comando close. Nel main tramite il range leggo i valori dal channel e il ciclo si interrompe da solo. Notate che in questo caso il valore restituito dal range non l’indice ma il valore stesso.<\/p>\n\n\n\n
Go permette di gestire la lettura di pi\u00f9 channel concorrenti utilizzando la stessa goroutine. Per fare ci\u00f2 si avvale del comando select che consente la lettura dei valori da channel differenti. Come sintassi ricorda molto lo switch case.<\/p>\n\n\n\n
go func() {\n\t\tcanale6 <- \"1\"\n\t\tcanale6 <- \"2\"\n\t}()\n\n\tgo func() {\n\t\tcanale7 <- \"3\"\n\t\ttime.Sleep(time.Second * 3)\n\t\tcanale7 <- \"4\"\n\t}()\n\n\tfor i := 0; i < 4; i++ {\n\t\tselect {\n\t\tcase mess1 := <-canale6:\n\t\t\tfmt.Println(mess1)\n\t\tcase mess2 := <-canale7:\n\t\t\tfmt.Println(mess2)\n\t\tdefault:\n\t\t\tfmt.Println(\"Niente\")\n\t\t}\n\t}<\/pre>\n\n\n\nNell’esempio ho creato 2 funzioni anonime che scrivono i messaggi su 2 channel separati, tramite il comando select inserito all’interno nel ciclo for recupero tutti i valori inviati. Nel caso di messaggi concorrenti la select sceglie casualmente quale processare per primo. Con lo statement default possiamo implementare della logica da eseguire qualora non sia presente alcun dato nei channel gestiti dal select. Senza default la select rimarr\u00e0 in attesa di messaggi dal channel ad ogni iterazione.<\/p>\n\n\n\n
Il costrutto select consente anche di implementare in modo agevole un meccanismo di timeout tramite la funzione After del package time.<\/p>\n\n\n\n
\tfor i := 0; i < 2; i++ {\n\t\tselect {\n\t\tcase mess1 := <-canale6:\n\t\t\tfmt.Println(mess1)\n\t\tcase <-time.After(time.Second * 2):\n\t\t\tfmt.Println(\"timeout\")\n\t\t}\n\t}<\/pre>\n\n\n\nLa funzione After simula la ricezione di un messaggio nel channel, in tal modo implementiamo una attesa di 2 secondi sul channel canale, trascorso il quale viene gestita la condizione di timeout.<\/p>\n\n\n\n
Infine qualora si voglia gestire l’accesso concorrente a risorse di pi\u00f9 goroutines Go mette a disposizioni le funzioni Lock e Unlock del package sync. I 2 comandi ci assicurano che solo un thread per volta potr\u00e0 eseguire il codice compreso tra i 2 statement<\/p>\n\n\n\n
func (cont *contatoreStruct) somma(val int) {\n\tvar mutex sync.Mutex\n\tmutex.Lock()\n\tcont.counter = cont.counter + val\n\tmutex.Unlock()\n}<\/pre>\n","protected":false},"excerpt":{"rendered":"Nell’articolo precedente abbiamo illustrato un primo meccanismo per notificare al ricevente la chiusura del channel, ovvero l’invio di una stringa dedicata che comunica la fine del flusso. Go mette a disposizione la funzione close con cui esplicitare che il canale \u00e8 stato chiuso, la chiusura non \u00e8 una operazione obbligatoria come nel caso dei file, … Continua la lettura di TUTORIAL GO – GESTIRE LA COMUNICAZIONE CON I CHANNEL<\/span>