pool

Documentation

Index

• Variables
• type ThreadPool
  • func New(n int) *ThreadPool
  • func (tp *ThreadPool) Add(f func(context.Context) error)
  • func (tp *ThreadPool) DoneAddingJobs()
  • func (tp *ThreadPool) Run() error

Variables

var ThreadPoolCancelled = fmt.Errorf("thread pool cancelled")

Types

type ThreadPool

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

func New

func New(n int) *ThreadPool

func (*ThreadPool) Add

func (tp *ThreadPool) Add(f func(context.Context) error)

func (*ThreadPool) DoneAddingJobs

func (tp *ThreadPool) DoneAddingJobs()

func (*ThreadPool) Run

func (tp *ThreadPool) Run() error