executor

Documentation

Overview

Package executor is defined below

Index

• type Executor
  • func NewExecutor() Executor
• type Task

Types

type Executor

type Executor interface {
	Run()
	Submit(task Task) bool
	// Terminate will gracefully shut down the executor, stop allowing more tasks but will continue to process submitted tasks
	Terminate()
	// AwaitTermination will terminate the executor gracefully and wait for all outstanding tasks to be completed
	// AwaitTeramintion may be called after Terminate or TerminateNow.
	AwaitTermination()
}

Executor interface

func NewExecutor

func NewExecutor() Executor

NewExecutor allocates a new executor with default parameters.

type Task

type Task func()

Task represents a task that can be submitted to an executor