-
Notifications
You must be signed in to change notification settings - Fork 0
/
update.go
63 lines (54 loc) · 1.18 KB
/
update.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
package main
import (
"time"
)
type Updateable interface {
Update(timeLeft time.Duration) error
}
type Updater struct {
queue []Updateable
total, empty int64
}
func (receiver *Updater) Add(object Updateable) {
receiver.queue = append(receiver.queue, object)
receiver.total++
}
func (receiver *Updater) Remove(object Updateable) {
for indx, candidate := range receiver.queue {
if object == candidate {
receiver.queue[indx] = nil
receiver.empty++
}
}
}
func (receiver *Updater) Compact() {
i, j := 0, 0
for i < len(receiver.queue) {
if receiver.queue[i] == nil {
//
} else {
receiver.queue[j] = receiver.queue[i]
j++
}
i++
}
receiver.queue = receiver.queue[0:j]
receiver.total = int64(len(receiver.queue))
receiver.empty = 0
}
func (receiver *Updater) NeedCompact() bool {
return receiver.total > 100 && receiver.empty > 0 && receiver.total/receiver.empty < 2
}
func (receiver *Updater) Execute(timeLeft time.Duration) {
for _, object := range receiver.queue {
if object == nil {
continue
}
object.Update(timeLeft)
}
}
func NewUpdater(queueSize int) (*Updater, error) {
return &Updater{
queue: make([]Updateable, 0, queueSize),
}, nil
}