schedule

Documentation

Index

• type TimedSched
  • func NewTimedSched(parallel int) *TimedSched
  • func (ts *TimedSched) Close()
  • func (ts *TimedSched) Put(f func(), deadline time.Time)

Types

type TimedSched

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

TimedSched represents the control struct for timed parallel scheduler.

var System *TimedSched = NewTimedSched(runtime.NumCPU())

System is a global timed scheduler.

func NewTimedSched

func NewTimedSched(parallel int) *TimedSched

NewTimedSched creates a parallel-scheduler with given parallelization.

func (*TimedSched) Close

func (ts *TimedSched) Close()

Close terminates this scheduler.

func (*TimedSched) Put

func (ts *TimedSched) Put(f func(), deadline time.Time)

Put a function 'f' awaiting to be executed at 'deadline'.