Skip to content

Instantly share code, notes, and snippets.

@kachayev
Last active December 11, 2015 17:29
Show Gist options
  • Star 4 You must be signed in to star a gist
  • Fork 2 You must be signed in to fork a gist
  • Save kachayev/4634932 to your computer and use it in GitHub Desktop.
Save kachayev/4634932 to your computer and use it in GitHub Desktop.
Solve "Sleeping Barber Problem" with Golang (more about problem - http://en.wikipedia.org/wiki/Sleeping_barber_problem)
package main
import (
"fmt"
"time"
"math/rand"
)
const (
CUTTING_TIME = 20
BARBERS_AMOUNT = 1
HALL_SITS_AMOUNT = 3
)
type Barber struct {
val int
}
type Client struct {
val int
}
func main() {
clients := make(chan *Client)
go clientProducer(clients)
go BarberShop(clients)
time.Sleep(2 * time.Second)
}
func clientProducer(clients chan *Client) {
for {
time.Sleep(time.Duration(rand.Intn(28) + 7) * time.Millisecond)
clients <- &Client{}
}
}
func cutHear(barber *Barber, client *Client, finished chan *Barber) {
// Cutting hear
time.Sleep(CUTTING_TIME * time.Millisecond)
finished <- barber
}
func BarberShop(clients <-chan *Client) {
freeBarbers := []*Barber{}
waitingClient := []*Client{}
syncBarberChan := make(chan *Barber)
//creating barbers
for i := 0; i < BARBERS_AMOUNT; i++ {
freeBarbers = append(freeBarbers, &Barber{})
}
for {
select {
case client := <-clients:
if len(freeBarbers) == 0 {
if len(waitingClient) < HALL_SITS_AMOUNT {
// client is waiting in the hall
waitingClient = append(waitingClient, client)
fmt.Printf("Client is waiting in hall (%v)\n", len(waitingClient))
} else {
// hall is full - bye-bye client
fmt.Println("No free space for client")
}
} else {
barber := freeBarbers[0]
freeBarbers = freeBarbers[1:]
fmt.Println("Client goes to barber")
go cutHear(barber, client, syncBarberChan)
}
// barber finish work
case barber := <-syncBarberChan:
if len(waitingClient) > 0 {
// get client from hall
client := waitingClient[0]
waitingClient = waitingClient[1:]
fmt.Printf("Take client from room (%v)\n", len(waitingClient))
go cutHear(barber, client, syncBarberChan)
} else {
// barber is going to sleep
fmt.Println("Barber idle")
freeBarbers = append(freeBarbers, barber)
}
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment