kettle/utl/workerPool_test.go

package utl

import (
	"testing"
	"time"
)

func TestWorkPool_Put(t *testing.T) {
	p := NewWorkPool(WithWorkPoolSize(16))

	num := 2
	for num > 0 {
		p.Put(func(timer *time.Timer) {
			time.Sleep(0 * time.Second)
		})
		num = num - 1
	}
	time.Sleep(time.Second)
}