kettle/wkrp/dispatcher_test.go

package wkrp

import (
	"fmt"
	"git.wanbits.io/joe/kettle/utl"
	"testing"
	"time"
)

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

	for i := 0; i < 100; i++ {
		d.Do(utl.NewJob(utl.IJobFn(func(inf interface{}) error {
			fmt.Println("did", inf.(int))
			return nil
		}), i))
	}

	time.Sleep(1 * time.Second)
}