mirrors/Iris
1
0
Fork 0
mirror of https://github.com/VolmitSoftware/Iris.git synced 2026-06-17 06:11:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Thanks Crazydev!

Browse Source
This commit is contained in:
RePixelatedMC
2023-12-07 14:27:08 +01:00
parent db43bc300e
commit ac4c00d3f2
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/src/main/java/com/volmit/iris/core/pregenerator/LazyPregenerator.java
+15 -3
View File
@@ -25,6 +25,7 @@ import org.bukkit.event.world.WorldUnloadEvent;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
@@ -145,12 +146,23 @@ public class LazyPregenerator extends Thread implements Listener {
private void tickGenerate(Position2 chunk) { private void tickGenerate(Position2 chunk) {
executorService.submit(() -> { executorService.submit(() -> {
CountDownLatch latch = new CountDownLatch(1);
if (PaperLib.isPaper()) { if (PaperLib.isPaper()) {
PaperLib.getChunkAtAsync(world, chunk.getX(), chunk.getZ(), true).thenAccept((i) -> Iris.verbose("Generated Async " + chunk)); PaperLib.getChunkAtAsync(world, chunk.getX(), chunk.getZ(), true)
.thenAccept((i) -> {
Iris.verbose("Generated Async " + chunk);
latch.countDown();
});
} else { } else {
J.s(() -> world.getChunkAt(chunk.getX(), chunk.getZ())); J.s(() -> {
Iris.verbose("Generated " + chunk); world.getChunkAt(chunk.getX(), chunk.getZ());
Iris.verbose("Generated " + chunk);
latch.countDown();
});
} }
try {
latch.await();
} catch (InterruptedException ignored) {}
lazyGeneratedChunks.addAndGet(1); lazyGeneratedChunks.addAndGet(1);
}); });
} }