job

package

v1.0.0 Latest Latest Go to latest Published: Jul 17, 2018 License: Apache-2.0 Imports: 2 Imported by: 16

Details

This section is empty.

This section is empty.

This section is empty.

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

Job represents job

func NewJob(task func()) Job

NewJob creates new Job

func (job *Job) Run()

Run executes one Job

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

Queue manages workers and job

func NewQueue(maxWorker uint) *Queue

NewQueue makes new manager

func (queue *Queue) Add(job Job)

Add new job

func (queue *Queue) ForceStop()

ForceStop forces job manager without waiting job complete

func (queue *Queue) Stop()

Stop stops all worker after all job get done

func (queue *Queue) Wait()

Wait until all job get done

type Worker struct {
	CloseCh chan bool
	// contains filtered or unexported fields
}

Worker subcribes manager's work queue and execute it

func NewWorker(queue *Queue) *Worker

NewWorker makes new working process

func (worker *Worker) Start()

Start consuming task