|
@@ -48,10 +48,10 @@ var reqLimitInit *reqLimit
|
|
|
|
|
|
func init() {
|
|
func init() {
|
|
xweb.AddAction(&Tags{})
|
|
xweb.AddAction(&Tags{})
|
|
- //创建执行池 等待池
|
|
|
|
- doPool := make(chan struct{}, qu.IntAll(config.Sysconfig["awaitNum"]))
|
|
|
|
- do := qu.IntAll(config.Sysconfig["awaitNum"])
|
|
|
|
|
|
+ do := qu.IntAll(config.Sysconfig["executionNum"])
|
|
wait := qu.IntAll(config.Sysconfig["awaitNum"])
|
|
wait := qu.IntAll(config.Sysconfig["awaitNum"])
|
|
|
|
+ //创建执行池 等待池
|
|
|
|
+ doPool := make(chan struct{}, do)
|
|
for i := 0; i < do; i++ {
|
|
for i := 0; i < do; i++ {
|
|
doPool <- struct{}{}
|
|
doPool <- struct{}{}
|
|
}
|
|
}
|