diff --git a/internal/uploader/uploader.go b/internal/uploader/uploader.go index 1128834..ac7cbf5 100644 --- a/internal/uploader/uploader.go +++ b/internal/uploader/uploader.go @@ -44,10 +44,12 @@ func StartUpload(ctx context.Context, logChan *chan string) { AddLog(logChan, `单文件上传线程: `+strconv.Itoa(config.APPConfig.ThreadCount)) AddLog(logChan, "===============================================") + //创建连接池 AddLog(logChan, "正在创建连接池(连接池可避免首次大量上传时出现网络错误)") api.InitConn() AddLog(logChan, "创建连接池完成,开始运行程序") + //清除进度 progress.Clear() //推送上传进度 @@ -74,6 +76,7 @@ func StartUpload(ctx context.Context, logChan *chan string) { for { uploadData(ctx, logChan) + //延时1分钟运行 select { case <-ctx.Done(): return