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

More noise generators

Browse Source
This commit is contained in:
Daniel Mills
2021-07-25 11:31:39 -04:00
parent 1b85417ae6
commit 14e16c874e
8 changed files with 1264 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/java/com/volmit/iris/engine/parallel/BurstExecutor.java
View File

@@ -21,9 +21,7 @@ package com.volmit.iris.engine.parallel;
import com.volmit.iris.Iris;
import com.volmit.iris.util.collection.KList;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.*;
@SuppressWarnings("ALL")
public class BurstExecutor {
@@ -81,4 +79,26 @@ public class BurstExecutor {
}
}
}
public boolean complete(long maxDur) {
synchronized (futures) {
if (futures.isEmpty()) {
return true;
}
try {
try {
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).get(maxDur, TimeUnit.MILLISECONDS);
} catch (TimeoutException e) {
return false;
}
futures.clear();
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
Iris.reportError(e);
}
}
return false;
}
}