CI / Go Backend (push) Canceled after 0s
初始化 monorepo: Go后端(7微服务) + Unity客户端(9模块) + 启动器 HTML5原型: Three.js 3D体素世界, Perlin噪声地形, 原版材质, 22种方块 Minecraft创造模式背包: 双栏布局, 拖拽移动物品, 方向性元件引脚 AI助搭策划文档 + 客户端/服务端骨架 + Docker Compose + CI
74 lines
1.7 KiB
C#
74 lines
1.7 KiB
C#
namespace PCL.Network;
|
|
|
|
public sealed class NetManager
|
|
{
|
|
private static readonly Lazy<NetManager> _instance = new(() => new NetManager());
|
|
public static NetManager Instance => _instance.Value;
|
|
|
|
public Dictionary<string, DownloadFile> Files { get; } = new();
|
|
public object LockFiles { get; } = new();
|
|
public ModBase.SafeList<PCL.Network.Loaders.LoaderDownload> Tasks { get; } = new();
|
|
public object LockRemain { get; } = new();
|
|
public int FileRemain
|
|
{
|
|
get
|
|
{
|
|
lock (LockFiles)
|
|
return Files.Values.Count(file => file.State != NetState.Finished);
|
|
}
|
|
}
|
|
public object LockDone { get; } = new();
|
|
public long DownloadDone
|
|
{
|
|
get
|
|
{
|
|
lock (LockDone)
|
|
return field;
|
|
}
|
|
set
|
|
{
|
|
lock (LockDone)
|
|
field = value;
|
|
}
|
|
}
|
|
|
|
public long Speed
|
|
{
|
|
get
|
|
{
|
|
lock (LockFiles)
|
|
return Files.Values.Sum(file => file.Speed);
|
|
}
|
|
}
|
|
|
|
public int ThreadCount
|
|
{
|
|
get
|
|
{
|
|
lock (LockFiles)
|
|
return Files.Values.Sum(file => file.ActiveThreads);
|
|
}
|
|
}
|
|
|
|
public void Start(PCL.Network.Loaders.LoaderDownload task)
|
|
{
|
|
lock (LockFiles)
|
|
{
|
|
Tasks.Remove(task);
|
|
Tasks.Add(task);
|
|
foreach (var file in task.files)
|
|
Files[file.LocalPath] = file;
|
|
}
|
|
}
|
|
|
|
public void Finish(PCL.Network.Loaders.LoaderDownload task)
|
|
{
|
|
lock (LockFiles)
|
|
{
|
|
Tasks.Remove(task);
|
|
foreach (var file in task.files)
|
|
Files.Remove(file.LocalPath);
|
|
}
|
|
}
|
|
}
|