forked from alexey-ernest/go-hft-orderbook
-
Notifications
You must be signed in to change notification settings - Fork 0
/
ordersqueue.go
71 lines (60 loc) · 1.03 KB
/
ordersqueue.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
package hftorderbook
// Doubly linked orders queue
// TODO: this should be compared with ring buffer queue performance
type ordersQueue struct {
head *Order
tail *Order
size int
}
func NewOrdersQueue() ordersQueue {
return ordersQueue{}
}
func (this *ordersQueue) Size() int {
return this.size
}
func (this *ordersQueue) IsEmpty() bool {
return this.size == 0
}
func (this *ordersQueue) Enqueue(o *Order) {
tail := this.tail
this.tail = o
if tail != nil {
tail.Next = o
o.Prev = tail
}
if this.head == nil {
this.head = o
}
this.size++
}
func (this *ordersQueue) Dequeue() *Order {
if this.size == 0 {
return nil
}
head := this.head
if this.tail == this.head {
this.tail = nil
}
this.head = this.head.Next
this.size--
return head
}
func (this *ordersQueue) Delete(o *Order) {
prev := o.Prev
next := o.Next
if prev != nil {
prev.Next = next
}
if next != nil {
next.Prev = prev
}
o.Next = nil
o.Prev = nil
this.size--
if this.head == o {
this.head = next
}
if this.tail == o {
this.tail = prev
}
}