taskpool

Documentation

Overview

Package taskpool provides limited pool running task

Index

• type TaskPool
  • func New(workerCount, poolSize int) TaskPool
  • func (tp TaskPool) Close()
  • func (tp TaskPool) Run(task func())
  • func (tp TaskPool) TryRun(task func()) bool

Types

type TaskPool

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

TaskPool limited pool

func New

func New(workerCount, poolSize int) TaskPool

New returns task pool with workerCount and poolSize

func (TaskPool) Close

func (tp TaskPool) Close()

Close the pool, the function is concurrent unsafe

func (TaskPool) Run

func (tp TaskPool) Run(task func())

Run add task to pool, block if pool is full

func (TaskPool) TryRun

func (tp TaskPool) TryRun(task func()) bool

TryRun try to add task to pool, return immediately