Repo-Mirror/Iris-World-Engine
9
0
Fork 0
mirror of https://github.com/VolmitSoftware/Iris.git synced 2025-12-28 11:39:07 +00:00
Code Issues Releases Activity

Cleanup components

Browse Source
This commit is contained in:
Daniel Mills
2021-08-09 09:26:22 -04:00
parent 378f735e9f
commit 037473f2e1
6 changed files with 179 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/volmit/iris/util/parallel/BurstExecutor.java
View File

@@ -21,6 +21,7 @@ package com.volmit.iris.util.parallel;
import com.volmit.iris.Iris;
import com.volmit.iris.util.collection.KList;
import java.util.List;
import java.util.concurrent.*;
@SuppressWarnings("ALL")
@@ -42,7 +43,7 @@ public class BurstExecutor {
}
}
public BurstExecutor queue(KList<Runnable> r) {
public BurstExecutor queue(List<Runnable> r) {
synchronized (futures) {
for (Runnable i : r) {
CompletableFuture<Void> c = CompletableFuture.runAsync(i, executor);

3
src/main/java/com/volmit/iris/util/parallel/MultiBurst.java
View File

@@ -26,6 +26,7 @@ import com.volmit.iris.util.math.M;
import com.volmit.iris.util.scheduling.J;
import com.volmit.iris.util.scheduling.Looper;
import java.util.List;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicLong;
import java.util.function.Supplier;
@@ -99,7 +100,7 @@ public class MultiBurst {
burst(r.length).queue(r).complete();
}
public void burst(KList<Runnable> r) {
public void burst(List<Runnable> r) {
burst(r.size()).queue(r).complete();
}