executor

Documentation

Index

• Constants
• type Executor
  • func NewExecutor(pool *ExecutorPool) *Executor
  • func (executor *Executor) CancelTask()
  • func (executor *Executor) Start(ctx context.Context)
  • func (executor *Executor) Stop()
• type ExecutorPool
  • func NewExecutorPool() *ExecutorPool
  • func (pool *ExecutorPool) AddTask(taskID int64)
  • func (pool *ExecutorPool) CancelTask(taskID int64)
  • func (pool *ExecutorPool) RemoveTask(taskID int64)
  • func (pool *ExecutorPool) Start()
  • func (pool *ExecutorPool) Stop()
• type ReadyTask
• type Synchronizer
  • func NewSynchronizer(coordinator *coordinator.Coordinator) *Synchronizer
  • func (synchronizer *Synchronizer) Restart()
  • func (synchronizer *Synchronizer) Start()
  • func (synchronizer *Synchronizer) Stop() *context.Context
  • func (synchronizer *Synchronizer) Sync()

Constants

const (
	QUEUE_SIZE = 10
	WORKER_NUM = 8
)

Types

type Executor

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

func NewExecutor

func NewExecutor(pool *ExecutorPool) *Executor

func (*Executor) CancelTask

func (executor *Executor) CancelTask()

func (*Executor) Start

func (executor *Executor) Start(ctx context.Context)

func (*Executor) Stop

func (executor *Executor) Stop()

type ExecutorPool

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

var OCS_EXECUTOR_POOL *ExecutorPool

func NewExecutorPool

func NewExecutorPool() *ExecutorPool

func (*ExecutorPool) AddTask

func (pool *ExecutorPool) AddTask(taskID int64)

func (*ExecutorPool) CancelTask

func (pool *ExecutorPool) CancelTask(taskID int64)

func (*ExecutorPool) RemoveTask

func (pool *ExecutorPool) RemoveTask(taskID int64)

func (*ExecutorPool) Start

func (pool *ExecutorPool) Start()

func (*ExecutorPool) Stop

func (pool *ExecutorPool) Stop()

type ReadyTask

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

type Synchronizer

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

var OCS_SYNCHRONIZER *Synchronizer

func NewSynchronizer

func NewSynchronizer(coordinator *coordinator.Coordinator) *Synchronizer

func (*Synchronizer) Restart

func (synchronizer *Synchronizer) Restart()

func (*Synchronizer) Start

func (synchronizer *Synchronizer) Start()

func (*Synchronizer) Stop

func (synchronizer *Synchronizer) Stop() *context.Context

func (*Synchronizer) Sync

func (synchronizer *Synchronizer) Sync()