spdis/voxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

More error logging

Browse Source
This commit is contained in:
mcrcortex
2025-03-09 12:05:08 +10:00
parent fd4d1d7910
commit 60b878d53c
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/me/cortex/voxy/common/thread/ServiceSlice.java
View File

@@ -13,7 +13,7 @@ import java.util.function.BooleanSupplier;
import java.util.function.Supplier; import java.util.function.Supplier;
public class ServiceSlice extends TrackedObject { public class ServiceSlice extends TrackedObject {
private final String name; final String name;
final int weightPerJob; final int weightPerJob;
volatile boolean alive = true; volatile boolean alive = true;
private final ServiceThreadPool threadPool; private final ServiceThreadPool threadPool;

7
src/main/java/me/cortex/voxy/common/thread/ServiceThreadPool.java
View File

@@ -3,6 +3,7 @@ package me.cortex.voxy.common.thread;
import me.cortex.voxy.common.Logger; import me.cortex.voxy.common.Logger;
import me.cortex.voxy.common.util.Pair; import me.cortex.voxy.common.util.Pair;
import java.util.Arrays;
import java.util.concurrent.Semaphore; import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
@@ -204,7 +205,11 @@ public class ServiceThreadPool {
public void shutdown() { public void shutdown() {
if (this.serviceSlices.length != 0) { if (this.serviceSlices.length != 0) {
throw new IllegalStateException("All service slices must be shutdown before thread pool can exit"); String remaining = "";
for (var service : this.serviceSlices) {
remaining += service.name + ", ";
}
throw new IllegalStateException("All service slices must be shutdown before thread pool can exit. Remaining: " + remaining);
} }
//Wait for the tasks to finish //Wait for the tasks to finish