utils

type Func ¶

type Func func()

type FuncArgs ¶

type FuncArgs func(args ...interface{})

type Task ¶

type Task struct {
	// contains filtered or unexported fields
}

func NewTask(f taskFunc, args ...interface{}) *Task

func (t *Task) Execute() error

type TaskPool ¶

type TaskPool struct {
	// contains filtered or unexported fields
}

================================================================ 多个线程，一个任务队列，多个线程竞争从队列中获取任务并执行

func NewTaskPool(threadSize, taskQueueSize int) *TaskPool

func (t *TaskPool) Start()

func (t *TaskPool) Stop()

func (t *TaskPool) Submit(task *Task)

type Thread ¶

type Thread struct {
	// contains filtered or unexported fields
}

=====================================================================

type ThreadPool ¶

type ThreadPool struct {
	// contains filtered or unexported fields
}

开启多个线程，每个线程都有一个独立的任务队列，所有队列并行执行

func NewThreadPool(poolSize, threadWorkSize int) *ThreadPool

func (d *ThreadPool) Start()

func (d *ThreadPool) Stop()

func (d *ThreadPool) Submit(threadId int, task *Task)