Version: v0.0.0-...-f87b766 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: May 28, 2022 License: MIT Imports: 6 Imported by: 9




This section is empty.


This section is empty.


This section is empty.


type TaskHandler

type TaskHandler func() error

TaskHandler Define function callbacks

type WorkPool

type WorkPool struct {
	// contains filtered or unexported fields

WorkPool serves incoming connections via a pool of workers

func New

func New(max int) *WorkPool

New new workpool and set the max number of concurrencies

func (*WorkPool) Do

func (p *WorkPool) Do(fn TaskHandler)

Do Add to the workpool and return immediately

func (*WorkPool) DoWait

func (p *WorkPool) DoWait(task TaskHandler)

DoWait Add to the workpool and wait for execution to complete before returning

func (*WorkPool) IsClosed

func (p *WorkPool) IsClosed() bool

IsClosed Has it been closed?

func (*WorkPool) IsDone

func (p *WorkPool) IsDone() bool

IsDone Determine whether it is complete (non-blocking)

func (*WorkPool) SetTimeout

func (p *WorkPool) SetTimeout(timeout time.Duration)

SetTimeout Setting timeout time

func (*WorkPool) Wait

func (p *WorkPool) Wait() error

Wait Waiting for the worker thread to finish executing

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL