refactor(upload): 优化文件上传服务的异步处理和调试输出
- 将同步Thread.Sleep替换为异步Task.Delay以提高性能 - 移除调试用的控制台输出语句 - 统一移除验证和进度相关的打印日志dev2.0
parent
0718a29850
commit
e68391d54a
|
|
@ -1014,7 +1014,7 @@ namespace Hopetry.Provider
|
||||||
.WithBucket(bucketName)
|
.WithBucket(bucketName)
|
||||||
.WithObject(objectName));
|
.WithObject(objectName));
|
||||||
|
|
||||||
Console.WriteLine($"验证成功!文件大小: {stat.Size} 字节, ETag: {stat.ETag}");
|
//Console.WriteLine($"验证成功!文件大小: {stat.Size} 字节, ETag: {stat.ETag}");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
|
|
|
||||||
|
|
@ -95,7 +95,7 @@ namespace Hopetry.Services
|
||||||
.Where(r => r.Id == id)
|
.Where(r => r.Id == id)
|
||||||
.ExecuteCommand();
|
.ExecuteCommand();
|
||||||
|
|
||||||
Console.WriteLine($"数据库更新结果: {result}, ID: {id}, Flag: {flag}");
|
//Console.WriteLine($"数据库更新结果: {result}, ID: {id}, Flag: {flag}");
|
||||||
return result > 0;
|
return result > 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -631,7 +631,7 @@ namespace HeBianGu.App.Disk
|
||||||
var pendingItems = UpLoadItems.Where(r => !r.Bool1).ToList();
|
var pendingItems = UpLoadItems.Where(r => !r.Bool1).ToList();
|
||||||
|
|
||||||
if (!pendingItems.Any())
|
if (!pendingItems.Any())
|
||||||
Thread.Sleep(500);
|
await Task.Delay(500); // 使用异步延时替代同步休眠
|
||||||
|
|
||||||
// 分批处理,避免一次性启动过多任务
|
// 分批处理,避免一次性启动过多任务
|
||||||
const int batchSize = 10;
|
const int batchSize = 10;
|
||||||
|
|
@ -835,7 +835,7 @@ namespace HeBianGu.App.Disk
|
||||||
? Math.Round((decimal)(CompleteItems.Count * 100/ (UpLoadItems.Count + CompleteItems.Count)) ,
|
? Math.Round((decimal)(CompleteItems.Count * 100/ (UpLoadItems.Count + CompleteItems.Count)) ,
|
||||||
2)
|
2)
|
||||||
: 0;
|
: 0;
|
||||||
Console.WriteLine($"当前上传进度:{Progress}%");
|
//Console.WriteLine($"当前上传进度:{Progress}%");
|
||||||
// 更新网盘空间页面状态
|
// 更新网盘空间页面状态
|
||||||
/*if (_explorerBehavior != null)
|
/*if (_explorerBehavior != null)
|
||||||
{
|
{
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue