work

package

v1.3.3 Latest Latest Go to latest Published: Dec 10, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Details

@Time : 2019-12-09 09:20 @Author : zr

This section is empty.

This section is empty.

This section is empty.

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

IntervalWork 间隔时间任务

func RegisterNewWork(intervalTime time.Duration, workHandler func(), onError OnError) *IntervalWork

func (i *IntervalWork) Join()

func (i *IntervalWork) Run()

func (i *IntervalWork) Stop()

type OnError func(err error)

type ScheduleDayWork struct {
	ScheduleTime time.Time
	// contains filtered or unexported fields
}

ScheduleWork 每日固定时间任务

func RegisterScheduleDayWork(schedule time.Time, workHandler func(), onError OnError) *ScheduleDayWork

func (s *ScheduleDayWork) Join()

func (s *ScheduleDayWork) Run()

func (s *ScheduleDayWork) Stop()

type Work interface {
	Run()
	Stop()
	Join()
}