taskengine

package

v1.0.15 Latest Latest Go to latest Published: May 21, 2022 License: Apache-2.0, Apache-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 Task interface {
	Run()
}

Task define the task interface

type TaskEngine struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

TaskEngine define the task engine

func New(ctx context.Context, name string, concurrencyLevel int, logger *zap.Logger) *TaskEngine

New create a new task engine

func (engine *TaskEngine) Schedule(task Task) bool

Schedule schedule a task running on engine

func (engine *TaskEngine) Shutdown()

Shutdown stop the task engine

type TaskFunc func()

TaskFunc define the task func type

func (f TaskFunc) Run()

Run implements the Task interface