kettle/wkrp/dispatcher_test.go

package wkrp

import (
	"fmt"
	"testing"
	"time"
)

func TestNewDispacher(t *testing.T) {
	d := NewDispacher(16)
	defer d.Stop()

	d.Do(IJobFn(func() error {
		time.Sleep(time.Second)
		fmt.Println("did")
		return nil
	}))
	time.Sleep(2 * time.Second)
}