From 9439191ed451a463a32ae026bf1c5baaddd654d1 Mon Sep 17 00:00:00 2001 From: M09Ic Date: Thu, 17 Nov 2022 05:26:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=B8=80=E4=B8=AAchannel?= =?UTF-8?q?=E6=8F=90=E5=89=8D=E5=85=B3=E9=97=AD,=20=E5=8F=AF=E8=83=BD?= =?UTF-8?q?=E5=AF=BC=E8=87=B4=E7=BB=93=E6=9E=9C=E6=97=A0=E6=B3=95=E6=AD=A3?= =?UTF-8?q?=E5=B8=B8=E8=BE=93=E5=87=BA=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/runner.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/runner.go b/internal/runner.go index 3c0f095..07ef3d3 100644 --- a/internal/runner.go +++ b/internal/runner.go @@ -10,6 +10,7 @@ import ( "github.com/panjf2000/ants/v2" "net/http" "sync" + "time" ) var BlackStatus = []int{400, 404, 410} @@ -37,6 +38,7 @@ type Runner struct { Offset int Limit int Deadline int + CheckOnly bool } func (r *Runner) Prepare(ctx context.Context) error { @@ -129,6 +131,7 @@ Loop: break } } + time.Sleep(100) // 延迟100ms, 等所有数据处理完毕 } func (r *Runner) Outputting() {