Function BenchmarkQueue

chan_queue_test.go:68–82

(b *testing.B)

}

func BenchmarkQueue(b *testing.B) {
	q := NewQueue(10, 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()
}