concurrency_test.go

package concurrency

import "testing"

func TestConcurrency(t *testing.T){
	testGroup := []struct{
		max int
		duration int
	}{
		{10,5},
		{5,10},
		{20,3},
		{30,1},
		{5,1},
		{100,1},
		{50,3},
	}
	for _,p := range testGroup{
		c := startConcurrency(p.max,p.duration)
		s := startSingle(p.max,p.duration)
		if c*3 > s{
			t.Errorf("Concurrency:%d, Single: %d",c,s)
		}
	}
}