mirror of
https://github.com/chainreactors/spray.git
synced 2025-09-15 19:50:18 +00:00
修复一个channel提前关闭, 可能导致结果无法正常输出的bug
This commit is contained in:
parent
b0ee744971
commit
9439191ed4
@ -10,6 +10,7 @@ import (
|
|||||||
"github.com/panjf2000/ants/v2"
|
"github.com/panjf2000/ants/v2"
|
||||||
"net/http"
|
"net/http"
|
||||||
"sync"
|
"sync"
|
||||||
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
var BlackStatus = []int{400, 404, 410}
|
var BlackStatus = []int{400, 404, 410}
|
||||||
@ -37,6 +38,7 @@ type Runner struct {
|
|||||||
Offset int
|
Offset int
|
||||||
Limit int
|
Limit int
|
||||||
Deadline int
|
Deadline int
|
||||||
|
CheckOnly bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *Runner) Prepare(ctx context.Context) error {
|
func (r *Runner) Prepare(ctx context.Context) error {
|
||||||
@ -129,6 +131,7 @@ Loop:
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
time.Sleep(100) // 延迟100ms, 等所有数据处理完毕
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *Runner) Outputting() {
|
func (r *Runner) Outputting() {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user