period_job

Documentation

Overview

* Package period_job 实现了周期性任务的定时触发执行。

manager := period_job.NewManager(ctx, cc)

job1 := &DemoJob{}
job2 := &DemoJob{}

manager.Run("Test", job1, 10*time.Millisecond)
manager.Run("Test2", job2, 20*time.Millisecond)

manager.Wait()

Index

• type Job
• type Manager
  • func NewManager(ctx context.Context, cc container.Container) *Manager
  • func (jm *Manager) Pause(name string, pause bool)
  • func (jm *Manager) Paused(name string) bool
  • func (jm *Manager) Run(name string, job Job, interval time.Duration)
  • func (jm *Manager) Wait()

Types

type Job

type Job interface {
	Handle()
}

Job is a interface for a job

type Manager

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

Manager 周期性任务管理器

func NewManager

func NewManager(ctx context.Context, cc container.Container) *Manager

NewManager 创建一个Manager

func (*Manager) Pause

func (jm *Manager) Pause(name string, pause bool)

func (*Manager) Paused

func (jm *Manager) Paused(name string) bool

Paused return whether the named job has been paused

func (*Manager) Run

func (jm *Manager) Run(name string, job Job, interval time.Duration)

Run 启动周期性任务循环

func (*Manager) Wait

func (jm *Manager) Wait()

Wait 等待所有任务结束