saGo

README

go一些特性封装

Routine

通过GoRoutine进行异步处理 可以控制routine最大并发数量 可以控制整体执行最大时间 单个GoRoutine执行时间无法控制

Documentation

Index

• type Routine
  • func NewRoutine(routineMaxCnt int, routineMaxTime time.Duration, ...) *Routine
  • func (r *Routine) Do(params interface{})

Types

type Routine

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

func NewRoutine

func NewRoutine(routineMaxCnt int, routineMaxTime time.Duration, handle func(params interface{})) *Routine

NewRoutine @Description: 通过channel，分发事务，控制事务并发数量 @param routineMaxCnt 协程数量 @param routineMaxTime 所有任务执行完最大总时间。单个任务协程无法被打断，时间控制没有意义。 @param handle @return *Routine

func (*Routine) Do

func (r *Routine) Do(params interface{})

Do @Description: 执行协程任务，任务数量大于最大协程数时会阻塞 @receiver r @param params