diff --git a/core/src/main/java/com/boydti/fawe/example/DefaultFaweQueueMap.java b/core/src/main/java/com/boydti/fawe/example/DefaultFaweQueueMap.java index 9f44fbde..fef1c661 100644 --- a/core/src/main/java/com/boydti/fawe/example/DefaultFaweQueueMap.java +++ b/core/src/main/java/com/boydti/fawe/example/DefaultFaweQueueMap.java @@ -26,7 +26,11 @@ public class DefaultFaweQueueMap implements IFaweQueueMap { @Override public FaweChunk put(Long key, FaweChunk value) { if (parent.getProgressTask() != null) { - parent.getProgressTask().run(FaweQueue.ProgressType.QUEUE, size() + 1); + try { + parent.getProgressTask().run(FaweQueue.ProgressType.QUEUE, size() + 1); + } catch (Throwable e) { + e.printStackTrace(); + } } return super.put(key, value); } diff --git a/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java b/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java index 3a9e863d..be86dc20 100644 --- a/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java +++ b/core/src/main/java/com/boydti/fawe/example/MappedFaweQueue.java @@ -205,7 +205,11 @@ public abstract class MappedFaweQueue extends FaweQueue { public void runTasks() { super.runTasks(); if (getProgressTask() != null) { - getProgressTask().run(ProgressType.DONE, 1); + try { + getProgressTask().run(ProgressType.DONE, 1); + } catch (Throwable e) { + e.printStackTrace(); + } } ArrayDeque tmp = new ArrayDeque<>(tasks); tasks.clear(); diff --git a/core/src/main/java/com/boydti/fawe/object/FaweQueue.java b/core/src/main/java/com/boydti/fawe/object/FaweQueue.java index 7ea7171d..a52c444f 100644 --- a/core/src/main/java/com/boydti/fawe/object/FaweQueue.java +++ b/core/src/main/java/com/boydti/fawe/object/FaweQueue.java @@ -397,7 +397,11 @@ public abstract class FaweQueue { this.notifyAll(); } if (getProgressTask() != null) { - getProgressTask().run(ProgressType.DONE, 1); + try { + getProgressTask().run(ProgressType.DONE, 1); + } catch (Throwable e) { + e.printStackTrace(); + } } while (!tasks.isEmpty()) { Runnable task = tasks.poll();