Function queueP2Test

queues/testutils_test.go:108–118

(t *testing.T, q Queue)

}

func queueP2Test(t *testing.T, q Queue) {
	runParallelTest(t, func(N int) {
		for i := 0; i < N; i += 1 {
			q.Enqueue(i)
			_, ok := q.Dequeue()
			if !ok {
				t.Fatalf("Was unable to get value")
			}
		}
	})
}