Function BenchmarkListQueue

list_queue_test.go:65–79

(b *testing.B)

}

func BenchmarkListQueue(b *testing.B) {
	q := NewListQueue(100)
	q.Run()

	b.ResetTimer()
	b.RunParallel(func(pb *testing.PB) {
		for pb.Next() {
			job := NewJob("", func(v interface{}) {
				_ = v
			})
			q.Push(job)
		}
	})
	q.Terminate()
}