Thread in Go (al massimo sola lettura)

• Il prof crea un for annidato

• quello esterno è infinito e stampa ciclicamente un asterisco

• quello interno termina alla fine di un tempo specificato → 500 millisecondi, implementato con la libreria time

• il corpo del for interno è vuoto, il for serve solo ripetere quello esterno esclusivamente quando termina il tempo

• Implementa al posto del for interno una system call Sleep che mette in pausa il processo per un tempo specificato, quindi lancerà un interrupt di clock non appena passano i 500ms

• Crea molteplici threads chiamati dal main che stampano per 10s

• Per ognuno specifica 2 parametri in input, la stringa da stampare e un intero per determinare ogni quanto tempo nello sleep

• ogni thread ha la sua implementazione del for contenente il codice di stampa e di attesa
Nel main

• ho le chiamate ai threads

• Aggiunge 10s di sleep dopo le chiamate, nel main

• anche se 2 thread hanno lo stesso tempo, nn saranno stampati simultaneamente, lo scheduler sceglie quale prioritizzare

• Diversamente da una funzione, la terminazione di un thread nn si può controllare dall’esterno, quindi usa una variabile globale flag e le assegna il valore 1, ciclo for implementato in ogni thread prima era infinito, ora cicla solo se flag=1

• nel main specifica che passati i 10s, la flag = 0 ed i threads terminano

• seguono altri 5s, in cui il programma è ancora aperto, poi si chiude

• Mancanza di località e flessibilità
Se in futuro volessi aggiungere altre flag per terminare ogni thread in momenti differenti, dovrei inizializzarli globalmente e implementare manualmente il nome delle variabili nelle chiamate del main e in ogni thread

• parametrizzo anche la flag (3° parametro), e lo passo non per valore (pk ne passerei solo una copia ed io voglio poi cambiare valore a tutti i flag on modo flessibile dal main) bensì per puntatore, in questo modo posso specificare quale variabile assegnare dalle chiamate nel main ed i thread si adeguano automaticamente

• In questo modo qualsiasi modifica al valore di flag nel main influenza anche il thread senza necessità di aggiornamenti manuali

flag1 := 1
flag2 := 1
go bumper("*", 333, &flag1) // Gruppo 1 usa flag1
go bumper("?", 444, &flag2) // Gruppo 2 usa flag2


func bumper(mark string, delay int, &flag) { //se cambio nome variabile, il valore rimane pk passo il puntatore    
        fmt.Print(mark)
    }
}

• questo problema si verificherebbe anche in caso di variabile globale

package main

import (
	"fmt"
	"time"
)

type Account struct {
	balance int
}

func sleep(t int) {
	time.Sleep(time.Duration(t) * time.Millisecond)
}

func main() {
	account := Account{1000}
	invest := 1
	thinkTime := 10 // set this to 0 to see data inconsistency
	watchTime := 500

	go broker(&account, invest, thinkTime)
	go broker(&account, invest, thinkTime)
	go observer(&account, watchTime)

	sleep(10000)
}

func broker(a *Account, qtt int, delay int) {
	for {
		a.balance -= qtt
		sleep(delay)
		a.balance += qtt
	}
}

func observer(a *Account, delay int) {
	for {
		fmt.Println(a.balance)
		sleep(delay)
	}
}