spdis/voxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Replace spinlock with a wait loop, freeing up a cpu thread during import

Browse Source
This commit is contained in:
mcrcortex
2025-01-31 18:39:05 +10:00
parent 64067d9ba5
commit d373b806ed
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/me/cortex/voxy/commonImpl/importers/WorldImporter.java
View File

@@ -159,7 +159,11 @@ public class WorldImporter {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
while ((this.totalChunks.get()-this.chunksProcessed.get() > 10_000) && this.isRunning) { while ((this.totalChunks.get()-this.chunksProcessed.get() > 10_000) && this.isRunning) {
Thread.onSpinWait(); try {
Thread.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
} }
if (!this.isRunning) { if (!this.isRunning) {
onCompletion.accept(this.totalChunks.get()); onCompletion.accept(this.totalChunks.get());
@@ -168,7 +172,12 @@ public class WorldImporter {
} }
this.threadPool.blockTillEmpty(); this.threadPool.blockTillEmpty();
while (this.chunksProcessed.get() != this.totalChunks.get() && this.isRunning) { while (this.chunksProcessed.get() != this.totalChunks.get() && this.isRunning) {
Thread.onSpinWait(); Thread.yield();
try {
Thread.sleep(10);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
} }
onCompletion.accept(this.totalChunks.get()); onCompletion.accept(this.totalChunks.get());
this.worker = null; this.worker = null;