协程池类

Documentation

Overview

包grpool实现了可重用的goroutine池。 md5:8908f4659795e87e

Index

• func Add(ctx context.Context, f X函数类型_Func) error
• func AddWithRecover(ctx context.Context, userFunc X函数类型_Func, ...) error
• func Jobs() int
• func Size() int
• type X函数类型_Func
• type X函数类型_RecoverFunc
• type X结构_协程池
  • func New(limit ...int) *X结构_协程池
  • func (p *X结构_协程池) Add(ctx context.Context, f X函数类型_Func) error
  • func (p *X结构_协程池) AddWithRecover(ctx context.Context, userFunc X函数类型_Func, ...) error
  • func (p *X结构_协程池) Cap() int
  • func (p *X结构_协程池) Close()
  • func (p *X结构_协程池) IsClosed() bool
  • func (p *X结构_协程池) Jobs() int
  • func (p *X结构_协程池) Size() int

Functions

func Add

func Add(ctx context.Context, f X函数类型_Func) error

Add 将一个新任务添加到默认的 Goroutine 池中。 该任务将会异步执行。 md5:2edd63bb852da48c

func AddWithRecover

func AddWithRecover(ctx context.Context, userFunc X函数类型_Func, recoverFunc X函数类型_RecoverFunc) error

AddWithRecover 将一个新的任务推送到默认池中，指定一个恢复函数。

可选的 `recoverFunc` 在执行 `userFunc` 时遇到任何 panic 时被调用。如果未传递或给定 `nil`，则忽略来自 `userFunc` 的 panic。任务将异步执行。 md5:4b448b4fd7caa604

func Jobs

func Jobs() int

Jobs 返回默认goroutine池当前的任务数量。 md5:d9b300d28d86f6c3

func Size

func Size() int

Size 返回默认goroutine池中的当前goroutine数量。 md5:f66351deb380810c

Types

type X函数类型_Func

type X函数类型_Func func(ctx context.Context)

X函数类型_Func 是包含上下文参数的池函数。 md5:6974cc4f941bf840

type X函数类型_RecoverFunc

type X函数类型_RecoverFunc func(ctx context.Context, exception error)

X函数类型_RecoverFunc 是一个带有上下文参数的池运行时panic恢复函数。 md5:745651d2d0aad841

type X结构_协程池

type X结构_协程池 struct {
	// contains filtered or unexported fields
}

X结构_协程池 使用池管理goroutine。 md5:b07df489dc176e1c

func New

func New(limit ...int) *X结构_协程池

New 创建并返回一个新的 goroutine 池对象。 参数 `limit` 用于限制最大 goroutine 数量， 默认情况下不限制。 md5:523f5833750663c7

func (*X结构_协程池) Add

func (p *X结构_协程池) Add(ctx context.Context, f X函数类型_Func) error

Add 将一个新任务添加到池中。 该任务将会异步执行。 md5:69389d53e280086b

func (*X结构_协程池) AddWithRecover

func (p *X结构_协程池) AddWithRecover(ctx context.Context, userFunc X函数类型_Func, recoverFunc X函数类型_RecoverFunc) error

AddWithRecover 将指定的恢复函数推送到队列中执行新任务。

可选的 `recoverFunc` 在执行 `userFunc` 时发生任何 panic 时被调用。如果未传递或给定 nil，它将忽略来自 `userFunc` 的 panic。任务将异步执行。 md5:764d1260466b9a5d

func (*X结构_协程池) Cap

func (p *X结构_协程池) Cap() int

Cap 返回池的容量。 这个容量在创建池时定义。 如果没有限制，则返回-1。 md5:1c6cae16429df1b2

func (*X结构_协程池) Close

func (p *X结构_协程池) Close()

Close 关闭goroutine池，导致所有goroutines退出。 md5:3d9c73ed9b0f4643

func (*X结构_协程池) IsClosed

func (p *X结构_协程池) IsClosed() bool

IsClosed 返回池是否已关闭。 md5:85755176347bcfea

func (*X结构_协程池) Jobs

func (p *X结构_协程池) Jobs() int

Jobs 返回池中的当前任务数。 注意，它返回的不是工作器/goroutine的数量，而是任务的数量。 md5:c82d92b33047974c

func (*X结构_协程池) Size

func (p *X结构_协程池) Size() int

Size 返回当前池中的goroutine数量。 md5:247eb1685633ccc3