并发 通过channel、互斥锁、定时器三者结合,完成了一个并发处理的函数接口。 通过传入协程池数、超时时间来限制协程的并发处理(协程池的数量应该小于数据循环处理的次数)。 参数中指定待处理的数据以及循环的次数,以及注册回调函数来处理自己的数据。如果传入的参数是数组,那么在回调函数中通过协程调用的索引号即可判断需要处理的是第几个元素。 type HanleParam struct { Data interface{} `comment:待处理的数据,会传入回调函数中` Num int `comment:调用协程的次数` Mx *sync.Mutex `com