From 4ba8ecd3fdb903fbff4b76207d88f26be3734950 Mon Sep 17 00:00:00 2001
From: cyberpwn <danielmillst@gmail.com>
Date: Sat, 25 Sep 2021 08:55:19 -0400
Subject: [PATCH] Fix mode fail due to pres svc

---
 .../volmit/iris/core/service/PreservationSVC.java  | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/volmit/iris/core/service/PreservationSVC.java b/src/main/java/com/volmit/iris/core/service/PreservationSVC.java
index d054619c7..8c44e4a51 100644
--- a/src/main/java/com/volmit/iris/core/service/PreservationSVC.java
+++ b/src/main/java/com/volmit/iris/core/service/PreservationSVC.java
@@ -32,14 +32,16 @@ import com.volmit.iris.util.scheduling.Looper;
 import com.volmit.iris.util.stream.utility.CachedStream2D;
 
 import java.util.Comparator;
+import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.ExecutorService;
 
 public class PreservationSVC implements IrisService {
-    private final KList<Thread> threads = new KList<>();
-    private final KList<ExecutorService> services = new KList<>();
+    private final List<Thread> threads = new CopyOnWriteArrayList<>();
+    private final List<ExecutorService> services = new CopyOnWriteArrayList<>();
     private Looper dereferencer;
-    private final KList<MeteredCache> caches = new KList<>();
+    private final List<MeteredCache> caches = new CopyOnWriteArrayList<>();
 
     public void register(Thread t) {
         threads.add(t);
@@ -79,8 +81,8 @@ public class PreservationSVC implements IrisService {
     public void dereference() {
         IrisContext.dereference();
         IrisData.dereference();
-        threads.removeWhere((i) -> !i.isAlive());
-        services.removeWhere(ExecutorService::isShutdown);
+        threads.removeIf((i) -> !i.isAlive());
+        services.removeIf(ExecutorService::isShutdown);
         updateCaches();
     }
 
@@ -129,7 +131,7 @@ public class PreservationSVC implements IrisService {
 
     public void updateCaches()
     {
-        caches.removeWhere(MeteredCache::isClosed);
+        caches.removeIf(MeteredCache::isClosed);
     }
 
     public void registerCache(MeteredCache cache) {