Esercizio - Sincronizzazione in Go con canali, mutex e variabili condizione (problemi classici)

package main

import (
	"fmt"
	"sync"
	"time"
)

const (
	sedie   = 3
	clienti = 8
)

func main() {
	attesa := make(chan int, sedie) // sedie per i clienti in attesa
	var wg sync.WaitGroup
	var mu sync.Mutex // protegge i contatori
	serviti, persi := 0, 0
	finito := make(chan struct{})

	go func() { // barbiere
		for c := range attesa { // dorme se il canale e' vuoto
			time.Sleep(2 * time.Millisecond) // cut_hair()
			mu.Lock()
			serviti++
			mu.Unlock()
			fmt.Println("servito il cliente", c)
		}
		close(finito)
	}()

	for i := 0; i < clienti; i++ {
		wg.Add(1)
		go func(id int) {
			defer wg.Done()
			time.Sleep(time.Duration(id) * 500 * time.Microsecond) // arrivi scaglionati
			select {
			case attesa <- id: // c'e' una sedia libera: si siede
			default: // sedie piene: se ne va
				mu.Lock()
				persi++
				mu.Unlock()
				fmt.Println("il cliente", id, "se ne va")
			}
		}(i)
	}

	wg.Wait()
	close(attesa) // nessun altro cliente: il barbiere finira' i rimasti e uscira'
	<-finito
	fmt.Println("serviti", serviti, "persi", persi, "totale", serviti+persi)
}

package main

import (
	"fmt"
	"sync"
)

type Conto struct {
	mu    sync.Mutex
	sosp  *sync.Cond
	saldo int
}

func NuovoConto() *Conto {
	c := &Conto{}
	c.sosp = sync.NewCond(&c.mu)
	return c
}

func (c *Conto) Prelievo(cifra int) {
	c.mu.Lock()
	defer c.mu.Unlock()
	for c.saldo < cifra { // il saldo non deve diventare negativo
		c.sosp.Wait()
	}
	c.saldo -= cifra
}

func (c *Conto) Deposito(cifra int) {
	c.mu.Lock()
	defer c.mu.Unlock()
	c.saldo += cifra
	c.sosp.Broadcast() // avverte tutti i prelievi in attesa
}

func main() {
	conto := NuovoConto()
	var wg sync.WaitGroup
	for i := 0; i < 2; i++ {
		wg.Add(2)
		go func() {
			defer wg.Done()
			for k := 0; k < 5; k++ {
				conto.Prelievo(10)
			}
		}()
		go func() {
			defer wg.Done()
			for k := 0; k < 10; k++ {
				conto.Deposito(5)
			}
		}()
	}
	wg.Wait()
	fmt.Println("saldo finale =", conto.saldo, "(atteso 0)")
}

package main

import (
	"fmt"
	"sync"
)

const clientiAlGiorno = 3

func main() {
	first := make(chan struct{})  // Giovanni -> Giulio: cocktail pronto
	second := make(chan struct{}) // Giulio -> Giovanni: panino pronto
	var wg sync.WaitGroup
	wg.Add(2)

	go func() { // Giulio
		defer wg.Done()
		for i := 1; i <= clientiAlGiorno; i++ {
			fmt.Println("Giulio prepara il panino", i)
			<-first // aspetta che il cocktail sia pronto
			second <- struct{}{}
			fmt.Println("Giulio consegna il panino", i)
		}
	}()

	go func() { // Giovanni
		defer wg.Done()
		for i := 1; i <= clientiAlGiorno; i++ {
			fmt.Println("Giovanni prepara il cocktail", i)
			first <- struct{}{} // cocktail pronto
			<-second            // aspetta che il panino sia pronto
			fmt.Println("Giovanni consegna il cocktail", i)
		}
	}()

	wg.Wait()
}