goroutine

Documentation

Index

• func CheckGoroutineErr(errCtx context.Context) error
• type ConcurrentControl
  • func NewConcurrentControl(concurrentNum int) *ConcurrentControl
  • func (c *ConcurrentControl) CloseGoroutine()
  • func (c *ConcurrentControl) GetGoroutine()
  • func (c *ConcurrentControl) ReleaseConnGoroutine()

Functions

func CheckGoroutineErr

func CheckGoroutineErr(errCtx context.Context) error

Types

type ConcurrentControl

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

func NewConcurrentControl

func NewConcurrentControl(concurrentNum int) *ConcurrentControl

func (*ConcurrentControl) CloseGoroutine

func (c *ConcurrentControl) CloseGoroutine()

func (*ConcurrentControl) GetGoroutine

func (c *ConcurrentControl) GetGoroutine()

func (*ConcurrentControl) ReleaseConnGoroutine

func (c *ConcurrentControl) ReleaseConnGoroutine()