tk/dot
1
0
Fork 0
mirror of https://github.com/nsnail/dot.git synced 2025-10-14 21:02:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

<adjust>

Browse Source
This commit is contained in:
nsnail
2022-12-08 16:52:48 +08:00
parent 0b4e582bbd
commit 254e6f2a45
4 changed files with 10 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/Time/Main.cs
View File

@@ -78,15 +78,14 @@ public sealed class Main : ToolBase<Option>
var offset = GetNtpOffset(payload.Key);
if (offset == TimeSpan.Zero) {
payload.Value.State.Status(TaskStatusColumn.Statues.Failed);
payload.Value.IsIndeterminate(false).Increment(0);
}
else {
payload.Value.State.Status(TaskStatusColumn.Statues.Succeed);
payload.Value.State.Result(offset);
Interlocked.Increment(ref _successCnt);
payload.Value.IsIndeterminate(false).Increment(100);
}
payload.Value.StopTask();
return ValueTask.CompletedTask;
}
@@ -117,11 +116,9 @@ public sealed class Main : ToolBase<Option>
, new TaskStatusColumn() //
, new TaskResultColumn())
.StartAsync(async ctx => {
var tasks = new Dictionary<string, ProgressTask>();
foreach (var server in _ntpServers) {
var t = ctx.AddTask(server, false).IsIndeterminate();
tasks.Add(server, t);
}
var tasks = _ntpServers.ToDictionary(server => server
, server => ctx.AddTask(server, false)
.IsIndeterminate());
await Parallel.ForEachAsync(
tasks, new ParallelOptions { MaxDegreeOfParallelism = _MAX_DEGREE_OF_PARALLELISM }