Function TestNewQueue

queue_test.go:25–53

(t *testing.T)

)

func TestNewQueue(t *testing.T) {
	req := require.New(t)

	// test 4 threads
	q := NewQueue()
	m := NewHashMap()
	wg := sync.WaitGroup{}
	wg.Add(4)
	for i := 0; i < 4; i++ {
		go func(start, end int) {
			for i := start; i < end; i++ {
				q.Enque(i)
			}
			for i := start; i < end; i++ {
				m.Set(q.Deque(), nil)
			}
			wg.Done()
		}(i*10000, (i+1)*10000)
	}
	wg.Wait()
	req.Equal(0, q.Len())
	req.Nil(q.Deque())
	req.Equal(40000, m.Len())
	for i := 0; i < 40000; i++ {
		v, ok := m.Get(i)
		req.Nil(v)
		req.True(ok)
	}
}

func BenchmarkLockfreeQueue(b *testing.B) {
	for i := 0; i < b.N; i++ {