-
Notifications
You must be signed in to change notification settings - Fork 0
/
philosophers.go
84 lines (76 loc) · 1.65 KB
/
philosophers.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
package main
import (
"context"
"errors"
log "github.com/sirupsen/logrus"
"sync"
"time"
)
var logger = log.New()
func createForks(info *Info) []Fork {
forks := make([]Fork, info.NumOfPhilos)
for i := range forks {
forks[i] = make(Fork, 1)
}
return forks
}
func closeForks(forks []Fork) {
for _, v := range forks {
close(v)
}
}
func (info *Info) start(forks []Fork) {
var wg sync.WaitGroup
wg.Add(info.NumOfPhilos)
logger.Info("Starting ...")
ctx, cancel := context.WithCancel(context.Background())
philos := make([]*Philo, info.NumOfPhilos)
for i := range philos {
philos[i] = &Philo{
Id: i + 1,
MealCount: info.NumOfMeals,
RightFork: forks[(i+1)%info.NumOfPhilos],
LeftFork: forks[i%info.NumOfPhilos],
Info: info,
LastEating: time.Now(),
}
i := i
go func() {
defer wg.Done()
philos[i].lifeСircle(ctx)
}()
}
endCh := make(chan bool)
go checker(philos, endCh)
for range endCh {
<-endCh
}
cancel()
wg.Wait()
}
func checkValid(info *Info) error {
switch {
case info.NumOfPhilos < 2:
return errors.New("Need more philosophers!\n")
case info.TimeToDie < 0:
return errors.New("Negative value of time to die!\n")
case info.TimeToEat < 0:
return errors.New("Negative value of time to eat!\n")
case info.TimeToSleep < 0:
return errors.New("Negative value of time to sleep!\n")
case info.NumOfMeals < 0:
return errors.New("Negative value of meals!\n")
default:
return nil
}
}
func philosophers(info *Info) {
if err := checkValid(info); err != nil {
log.Fatal(err)
return
}
forks := createForks(info)
info.start(forks)
closeForks(forks)
logger.Info("😎 ENDING SIMULATION 😎")
}