-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathpauser.go
103 lines (81 loc) · 1.47 KB
/
pauser.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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
package go_engine_io_parser
import "sync"
type pauserStatus int
const (
statusNormal pauserStatus = iota
statusPausing
statusPaused
)
type pauser struct {
lock sync.Mutex
c *sync.Cond
worker int
status pauserStatus
pausing chan struct{}
paused chan struct{}
}
func newPauser() *pauser {
ret := &pauser{
pausing: make(chan struct{}),
paused: make(chan struct{}),
status: statusNormal,
}
ret.c = sync.NewCond(&ret.lock)
return ret
}
func (p *pauser) Pause() bool {
p.lock.Lock()
defer p.lock.Unlock()
switch p.status {
case statusPaused:
return false
case statusNormal:
close(p.pausing)
p.status = statusPausing
}
for p.worker != 0 {
p.c.Wait()
}
if p.status == statusPaused {
return false
}
close(p.paused)
p.status = statusPaused
p.c.Broadcast()
return true
}
func (p *pauser) Resume() {
p.lock.Lock()
defer p.lock.Unlock()
p.status = statusNormal
p.paused = make(chan struct{})
p.pausing = make(chan struct{})
}
func (p *pauser) Working() bool {
p.lock.Lock()
defer p.lock.Unlock()
if p.status == statusPaused {
return false
}
p.worker++
return true
}
func (p *pauser) Done() {
p.lock.Lock()
defer p.lock.Unlock()
if p.status == statusPaused || p.worker == 0 {
return
}
p.worker--
p.c.Broadcast()
}
func (p *pauser) PausingTrigger() <-chan struct{} {
p.lock.Lock()
defer p.lock.Unlock()
return p.pausing
}
func (p *pauser) PausedTrigger() <-chan struct{} {
p.lock.Lock()
defer p.lock.Unlock()
return p.paused
}