Sancaros/PSO2SERVER
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

异步执行

Browse Source
This commit is contained in:
Longfeng Qin 2024-09-12 12:15:17 +08:00
parent 179561ef91
commit 68114e9aa5
1 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
Server/Program.cs
View File

@ -200,9 +200,9 @@ namespace PSO2SERVER
await InitializeConfigurationAsync();
await InitializeDatabaseAsync();
InitializeQueryServers(QueryMode.AuthList, ServerShipProt, ServerShipProtNums); // Assuming this is synchronous
await InitializeQueryServers(QueryMode.AuthList, ServerShipProt, ServerShipProtNums); // Assuming this is synchronous
InitializeQueryServers(QueryMode.ShipList, ServerShipListProt, ServerShipListProtNums); // Assuming this is synchronous
await InitializeQueryServers(QueryMode.ShipList, ServerShipListProt, ServerShipListProtNums); // Assuming this is synchronous
Logger.WriteInternal("服务器启动完成 " + DateTime.Now);
@ -236,18 +236,21 @@ namespace PSO2SERVER
});
}
public void InitializeQueryServers(QueryMode queryMode, int port, int portnums)
public async Task InitializeQueryServers(QueryMode queryMode, int port, int portnums)
{
if (portnums <= 0)
portnums = 1;
if (portnums > 0)
await Task.Run(() =>
{
for (var i = 0; i < portnums; i++)
if (portnums <= 0)
portnums = 1;
if (portnums > 0)
{
QueryServers.Add(new QueryServer(queryMode, "舰船", port + (100 * i)));
for (var i = 0; i < portnums; i++)
{
QueryServers.Add(new QueryServer(queryMode, "舰船", port + (100 * i)));
}
}
}
});
}
//private void InitializeQueryServers()