job

README

job-scheduler

Documentation

Index

• type ChannelScheduler
  • func NewChannelScheduler(ctx context.Context, concurrent int) *ChannelScheduler
  • func (s *ChannelScheduler) Add(job func()) error
  • func (s *ChannelScheduler) SetQueueSize(size int)
  • func (s *ChannelScheduler) Start()
• type QueueScheduler
  • func NewQueueScheduler(concurrent int64) *QueueScheduler
  • func (s *QueueScheduler) Add(job func())

Examples

• QueueScheduler

Types

type ChannelScheduler

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

func NewChannelScheduler

func NewChannelScheduler(ctx context.Context, concurrent int) *ChannelScheduler

NewChannelScheduler creates a new scheduler.

func (*ChannelScheduler) Add

func (s *ChannelScheduler) Add(job func()) error

func (*ChannelScheduler) SetQueueSize

func (s *ChannelScheduler) SetQueueSize(size int)

func (*ChannelScheduler) Start

func (s *ChannelScheduler) Start()

type QueueScheduler

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

Example

s := job.NewQueueScheduler(1)

var wg sync.WaitGroup
wg.Add(3)
s.Add(func() {
	defer wg.Done()
	fmt.Printf("hello")
})
s.Add(func() {
	defer wg.Done()
	fmt.Printf(" ")
})
s.Add(func() {
	defer wg.Done()
	fmt.Println("world")
})

wg.Wait()

Output:

hello world

func NewQueueScheduler

func NewQueueScheduler(concurrent int64) *QueueScheduler

func (*QueueScheduler) Add

func (s *QueueScheduler) Add(job func())