dispatcher

Documentation

Index

• type Dispatcher
  • func (dis *Dispatcher) Init(count uint8)
  • func (dis *Dispatcher) Shutdown()
• type Executor
  • func (exe *Executor) Enqueue(fun func()) bool
  • func (exe *Executor) WithTerminatedChan(fun func(chan struct{}))

Types

type Dispatcher

type Dispatcher struct {
	ExecutorCount uint8
	Executors     []*Executor
}

func (*Dispatcher) Init

func (dis *Dispatcher) Init(count uint8)

func (*Dispatcher) Shutdown

func (dis *Dispatcher) Shutdown()

type Executor

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

func (*Executor) Enqueue

func (exe *Executor) Enqueue(fun func()) bool

func (*Executor) WithTerminatedChan

func (exe *Executor) WithTerminatedChan(fun func(chan struct{}))