job

Documentation

Index

• type Job
• type JobQueue
  • func NewJobQueue(maxWorker, bufferRate int) *JobQueue
  • func (jobQueue *JobQueue) Close()
  • func (jobQueue *JobQueue) Submit(job Job)
  • func (jobQueue *JobQueue) SubmitTimeout(job Job, timeout int) bool

Types

type Job

type Job interface {
	Work()
}

Job job interface

type JobQueue

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

JobQueue job queue

func NewJobQueue

func NewJobQueue(maxWorker, bufferRate int) *JobQueue

NewJobQueue initialize a JobQueue and start it maxWorker max worker counts bufferRate queueSize = maxWorker * bufferRate

func (*JobQueue) Close

func (jobQueue *JobQueue) Close()

Close close this job queue

func (*JobQueue) Submit

func (jobQueue *JobQueue) Submit(job Job)

Submit submit job in queue

func (*JobQueue) SubmitTimeout

func (jobQueue *JobQueue) SubmitTimeout(job Job, timeout int) bool

SubmitTimeout submit job in queue with timeout in millisecond