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

Force stop bursters if longer than 7s

Browse Source
This commit is contained in:
cyberpwn 2021-09-25 08:40:35 -04:00
parent b0060bcb82
commit d2c373b27d
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -23,6 +23,7 @@ import com.volmit.iris.core.IrisSettings;
import com.volmit.iris.core.service.PreservationSVC; import com.volmit.iris.core.service.PreservationSVC;
import com.volmit.iris.util.collection.KList; import com.volmit.iris.util.collection.KList;
import com.volmit.iris.util.math.M; import com.volmit.iris.util.math.M;
import com.volmit.iris.util.scheduling.PrecisionStopwatch;
import java.util.List; import java.util.List;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
@ -151,9 +152,26 @@ public class MultiBurst {
public void close() { public void close() {
if (service != null) { if (service != null) {
service.shutdown(); service.shutdown();
PrecisionStopwatch p = PrecisionStopwatch.start();
try { try {
while (!service.awaitTermination(10, TimeUnit.SECONDS)) { while (!service.awaitTermination(1, TimeUnit.SECONDS)) {
Iris.info("Still waiting to shutdown burster..."); Iris.info("Still waiting to shutdown burster...");
if(p.getMilliseconds() > 7000)
{
Iris.warn("Forcing Shutdown...");
try
{
service.shutdownNow();
}
catch(Throwable e)
{
}
break;
}
} }
} catch (Throwable e) { } catch (Throwable e) {
e.printStackTrace(); e.printStackTrace();