oliverbooth/VpSharp
1
0
Fork 0
mirror of https://github.com/oliverbooth/VpSharp synced 2024-11-22 19:58:48 +00:00
Code Issues Wiki

Optimize query, run cell query in parallel and await WhenAll

Browse Source
This commit is contained in:
Oliver Booth 2022-12-04 17:42:45 +00:00
parent da02dd83b9
commit e2423eac39
No known key found for this signature in database
GPG Key ID: 32A00B35503AF634
1 changed files with 28 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
VpSharp/src/VirtualParadiseClient.Objects.cs
View File

@ -54,20 +54,42 @@ public sealed partial class VirtualParadiseClient
throw new ArgumentException("Range must be greater than or equal to 1."); throw new ArgumentException("Range must be greater than or equal to 1.");
} }
var cells = new HashSet<Cell>(); var hashSet = new HashSet<Cell>();
for (int x = center.X - radius; x < center.X + radius; x++) for (int x = center.X - radius; x < center.X + radius; x++)
for (int z = center.Z - radius; z < center.Z + radius; z++) for (int z = center.Z - radius; z < center.Z + radius; z++)
{ {
cells.Add(new Cell(x, z)); hashSet.Add(new Cell(x, z));
} }
foreach (Cell cell in cells.OrderBy(c => Vector2.Distance(c, center))) var cells = new List<Cell>(hashSet);
cells.Sort((a, b) =>
{ {
await foreach (VirtualParadiseObject vpObject in EnumerateObjectsAsync(cell).ConfigureAwait(false)) int x = a.X.CompareTo(b.X);
return x == 0 ? a.Z.CompareTo(b.Z) : x;
});
var objects = new List<VirtualParadiseObject>();
var tasks = new List<Task>();
foreach (Cell[] chunk in cells.Chunk(64))
{
Task task = Parallel.ForEachAsync(chunk, async (cell, token) =>
{ {
yield return vpObject; await foreach (VirtualParadiseObject current in EnumerateObjectsAsync(cell).WithCancellation(token))
} {
objects.Add(current);
}
});
tasks.Add(task);
}
await Task.WhenAll(tasks).ConfigureAwait(false);
foreach (VirtualParadiseObject current in objects)
{
yield return current;
} }
} }