jobserver

package

v1.1.45 Latest Latest Go to latest Published: Feb 18, 2024 License: GPL-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type IJob interface {
	Run() error
}

type Job struct {
	sync.WaitGroup

	log.InvokeLog
	// contains filtered or unexported fields
}

job，负责单个任务的执行

func NewJob(name string, f func()) *Job

func (j *Job) Name() string

func (j *Job) Run() error

func (j *Job) SetCoNum(num int64)

func (j *Job) Stop() error

type JobRunner struct {
	sync.WaitGroup

	log.InvokeLog
	// contains filtered or unexported fields
}

JobRunner,负责并发处理某个任务

func NewJobRunner(name string) *JobRunner

func (rn *JobRunner) AddExecute(name string, f func())

func (rn *JobRunner) AddJob(j IJob)

func (rn *JobRunner) Name() string

func (rn *JobRunner) Run() error

func (rn *JobRunner) Stop() error

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

func NewJobScheduler(name string, interval time.Duration, f IJob) *JobScheduler

func (sch *JobScheduler) Name() string

func (sch *JobScheduler) Run() error

func (sch *JobScheduler) Stop() error

type Task = func()