cherrySync

Documentation

Overview

Package cherrySync cherrySync file from https://github.com/beego/beego/blob/develop/core/utils/safemap.go

Index

• type Limit
  • func NewLimit(n int) Limit
  • func (l Limit) Borrow()
  • func (l Limit) Return() error
  • func (l Limit) TryBorrow() bool
• type WaitGroup
  • func (wg *WaitGroup) Add(fn func())
  • func (wg *WaitGroup) Wait()

Types

type Limit

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

Limit controls the concurrent requests.

func NewLimit

func NewLimit(n int) Limit

NewLimit creates a Limit that can borrow n elements from it concurrently.

func (Limit) Borrow

func (l Limit) Borrow()

Borrow borrows an element from Limit in blocking mode.

func (Limit) Return

func (l Limit) Return() error

Return returns the borrowed resource, returns error only if returned more than borrowed.

func (Limit) TryBorrow

func (l Limit) TryBorrow() bool

TryBorrow tries to borrow an element from Limit, in non-blocking mode. If success, true returned, false for otherwise.

type WaitGroup

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

WaitGroup 封装 sync.WaitGroup，提供更简单的 API

func (*WaitGroup) Add

func (wg *WaitGroup) Add(fn func())

Add 添加一个非阻塞的任务，任务在新的 Go 程执行

func (*WaitGroup) Wait

func (wg *WaitGroup) Wait()

Wait 等待所有任务执行完成