scheduler

Documentation

Index

• type SimpleScheduler
  • func (s *SimpleScheduler) ConfigureMasterWorkerChan(in chan engine.Request)
  • func (s *SimpleScheduler) Submit(r engine.Request)

Types

type SimpleScheduler

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

func (*SimpleScheduler) ConfigureMasterWorkerChan

func (s *SimpleScheduler) ConfigureMasterWorkerChan(in chan engine.Request)

实现 engine.Scheduler 接口的 ConfigureMasterWorkerChan(chan engine.Request) 方法 拿到 engine.Run() 方法创建的 in := make(chan Request)

func (*SimpleScheduler) Submit

func (s *SimpleScheduler) Submit(r engine.Request)

实现 engine.Scheduler 接口的 Submit(engine.Request) 方法