mirrors/Iris
1
0
Fork 0
mirror of https://github.com/VolmitSoftware/Iris.git synced 2025-07-18 18:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Performance Improvements

Browse Source
This commit is contained in:
Daniel Mills 2021-07-14 19:06:05 -04:00
parent 1c21b23e8e
commit d3c47fe1a4
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/volmit/iris/scaffold/hunk/io/HunkRegionSlice.java
View File

@ -90,7 +90,7 @@ public class HunkRegionSlice<T> {
} }
public synchronized void save() { public synchronized void save() {
BurstExecutor e = MultiBurst.burst.burst(); BurstExecutor e = MultiBurst.burstAux.burst();
for (ChunkPosition i : save.copy()) { for (ChunkPosition i : save.copy()) {
if (i == null) { if (i == null) {
continue; continue;

9
src/main/java/com/volmit/iris/scaffold/parallel/MultiBurst.java
View File

@ -25,16 +25,21 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
public class MultiBurst { public class MultiBurst {
public static final MultiBurst burst = new MultiBurst(Runtime.getRuntime().availableProcessors()); public static final MultiBurst burst = new MultiBurst("Iris Burster", 10, Runtime.getRuntime().availableProcessors());
public static final MultiBurst burstAux = new MultiBurst("Iris Aux Burster", 8, Runtime.getRuntime().availableProcessors()/2);
private final ExecutorService service; private final ExecutorService service;
private ExecutorService syncService; private ExecutorService syncService;
private int tid; private int tid;
public MultiBurst(int tc) { public MultiBurst(int tc) {
this("Iris Generator", 6, tc);
}
public MultiBurst(String name, int priority, int tc) {
service = Executors.newFixedThreadPool(tc, r -> { service = Executors.newFixedThreadPool(tc, r -> {
tid++; tid++;
Thread t = new Thread(r); Thread t = new Thread(r);
t.setName("Iris Generator " + tid); t.setName(name + " " + tid);
t.setPriority(6); t.setPriority(6);
t.setUncaughtExceptionHandler((et, e) -> t.setUncaughtExceptionHandler((et, e) ->
{ {