XXX_MAX_CONN = 5
var XXX_SEMAPHORE = make(chan struct{}, XXX_MAX_CONN)
func your_func() {
// 在开始处理请求时放入一个信号
XXX_SEMAPHORE <- struct{}{}
defer func() {
// 在完成请求后移除一个信号
<-XXX_SEMAPHORE
}()
}
XXX_MAX_CONN = 5
var XXX_SEMAPHORE = make(chan struct{}, XXX_MAX_CONN)
func your_func() {
// 在开始处理请求时放入一个信号
XXX_SEMAPHORE <- struct{}{}
defer func() {
// 在完成请求后移除一个信号
<-XXX_SEMAPHORE
}()
}
XXX_MAX_CONN = 5 var XXX_SEMAPHORE = make(chan struct{}, XXX_MAX_CONN) func your_func() { // 在开始处理请求时放入一个信号 XXX_SEMAPHORE <- struct{}{} defer func() { // 在完成请求后移除一个信号 <-XXX_SEMAPHORE }() }