weed/util/queue_unbounded_test.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

package util

import "testing"

func TestEnqueueAndConsume(t *testing.T) {

	q := NewUnboundedQueue()

	q.EnQueue("1", "2", "3")

	f := func(items []string) {
		for _, t := range items {
			println(t)
		}
		println("-----------------------")
	}
	q.Consume(f)

	q.Consume(f)

	q.EnQueue("4", "5")
	q.EnQueue("6", "7")
	q.Consume(f)

}