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