scheduler

Documentation

Index

• type QueuedScheduler
  • func (s *QueuedScheduler) Run()
  • func (s *QueuedScheduler) Submit(r engine.Request)
  • func (s *QueuedScheduler) WorkerChan() chan engine.Request
  • func (s *QueuedScheduler) WorkerReady(w chan engine.Request)
• type SimpleScheduler
  • func (s *SimpleScheduler) Run()
  • func (s *SimpleScheduler) Submit(r engine.Request)
  • func (s *SimpleScheduler) WorkerChan() chan engine.Request
  • func (s *SimpleScheduler) WorkerReady(w chan engine.Request)

Types

type QueuedScheduler

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

func (*QueuedScheduler) Run

func (s *QueuedScheduler) Run()

总控

func (*QueuedScheduler) Submit

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

func (*QueuedScheduler) WorkerChan

func (s *QueuedScheduler) WorkerChan() chan engine.Request

func (*QueuedScheduler) WorkerReady

func (s *QueuedScheduler) WorkerReady(w chan engine.Request)

有一个 worker ready了，可以负责去接受 request 了

type SimpleScheduler

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

func (*SimpleScheduler) Run

func (s *SimpleScheduler) Run()

func (*SimpleScheduler) Submit

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

func (*SimpleScheduler) WorkerChan

func (s *SimpleScheduler) WorkerChan() chan engine.Request

func (*SimpleScheduler) WorkerReady

func (s *SimpleScheduler) WorkerReady(w chan engine.Request)