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(NewJob(IJobFn(func(inf interface{}) error {
			time.Sleep(0 * time.Second)
			t.Log("num:", inf.(int))
			return nil
		}), num))
		num = num - 1
	}
	time.Sleep(time.Second)
}