bigmap/pointer_queue_test.go at master · worldOneo/bigmap · GitHub

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
package bigmap

import "testing"

func BenchmarkPointerQueue_Enqueue(b *testing.B) {
	queue := NewPointerQueue()
	for i := uint64(0); i < uint64(b.N); i++ {
		queue.Enqueue(i)
	}
}

func BenchmarkPointerQueue_Dequeue(b *testing.B) {
	queue := NewPointerQueue()
	for i := uint64(0); i < uint64(b.N); i++ {
		queue.Enqueue(i)
	}
	b.ResetTimer()
	for i := uint32(0); i < uint32(b.N); i++ {
		queue.Dequeue()
	}
}

func TestPointerQueue_Enqueue(t *testing.T) {
	queue := NewPointerQueue()
	for i := uint64(0); i < 3000; i++ {
		queue.Enqueue(i)
	}
}

func TestPointerQueue_Dequeue(t *testing.T) {
	queue := NewPointerQueue()
	for i := uint64(0); i < 3000; i++ {
		queue.Enqueue(i)
	}
	for i := uint64(0); i < 3000; i++ {
		k, ok := queue.Dequeue()
		if k != i || !ok {
			t.Fatalf("Item %d couldn't be dequeued ok=%t v=%d", i, ok, k)
		}
	}
	ptr, ok := queue.Dequeue()
	if ok {
		t.Fatalf("Dequeued empty Queue (%d, %t)", ptr, ok)
	}
}