gpool

Documentation

Index

• type GPool
  • func NewGPool(capacity int) *GPool
  • func (p *GPool) AddJob(job func(ctx context.Context) error)
  • func (p *GPool) Go(job func(ctx context.Context) error)
  • func (p *GPool) RunningCount() int64
  • func (p *GPool) Shutdown()
  • func (p *GPool) Wait()

Types

type GPool

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

func NewGPool

func NewGPool(capacity int) *GPool

NewGPool 创建并初始化具有指定容量的新GPool。

func (*GPool) AddJob

func (p *GPool) AddJob(job func(ctx context.Context) error)

AddJob 将新作业添加到池中。如果池已满，它将阻塞，直到有工作人员可用。

func (*GPool) Go

func (p *GPool) Go(job func(ctx context.Context) error)

Go 将任务提交到池中执行。

func (*GPool) RunningCount

func (p *GPool) RunningCount() int64

RunningCount 返回当前正在运行的任务数。

func (*GPool) Shutdown

func (p *GPool) Shutdown()

Shutdown 取消所有挂起的任务，并等待正在运行的任务完成。

func (*GPool) Wait

func (p *GPool) Wait()

Wait 直到所有提交的任务都完成。