Function BenchmarkLockfreeQueue

queue_test.go:55–73

(b *testing.B)

}

func BenchmarkLockfreeQueue(b *testing.B) {
	for i := 0; i < b.N; i++ {
		q := NewQueue()
		wg := sync.WaitGroup{}
		wg.Add(10)
		for i := 0; i < 10; i++ {
			go func(start, end int) {
				for i := start; i < end; i++ {
					q.Enque(i)
				}
				for i := start; i < end; i++ {
					q.Deque()
				}
				wg.Done()
			}(i*10000, (i+1)*10000)
		}
		wg.Wait()
	}
}

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