Some small fixes.

I forgot to refactor the tests so they actually compile...
Also fixed small issue where the dimension thread load function called a client-sided function on the server.
Fixed star-imports for style checking.

Author: BallOfEnergy1

src/main/java/com/gamma/spool/core/Spool.java

@@ -16,7 +16,11 @@
 import com.gamma.spool.config.ThreadsConfig;
 import com.gamma.spool.events.PlayerJoinTimeHandler;
 import com.gamma.spool.statistics.StatisticsManager;
-import com.gamma.spool.thread.*;
+import com.gamma.spool.thread.IThreadManager;
+import com.gamma.spool.thread.KeyedPoolThreadManager;
+import com.gamma.spool.thread.LBKeyedPoolThreadManager;
+import com.gamma.spool.thread.ManagerNames;
+import com.gamma.spool.thread.ThreadManager;
 import com.gamma.spool.util.caching.RegisteredCache;
 import com.gamma.spool.util.distance.DistanceThreadingUtil;
 import com.gamma.spool.watchdog.Watchdog;

src/main/java/com/gamma/spool/core/SpoolManagerOrchestrator.java

@@ -2,7 +2,11 @@
 
 import com.gamma.spool.config.ThreadManagerConfig;
 import com.gamma.spool.config.ThreadsConfig;
-import com.gamma.spool.thread.*;
+import com.gamma.spool.thread.ForkThreadManager;
+import com.gamma.spool.thread.IThreadManager;
+import com.gamma.spool.thread.KeyedPoolThreadManager;
+import com.gamma.spool.thread.LBKeyedPoolThreadManager;
+import com.gamma.spool.thread.ManagerNames;
 import com.gamma.spool.util.caching.RegisteredCache;
 import com.gamma.spool.util.distance.DistanceThreadingUtil;
 import com.gamma.spool.watchdog.Watchdog;

src/main/java/com/gamma/spool/mixin/minecraft/MinecraftServerMixin.java

@@ -168,11 +168,12 @@ public void updateTimeLightAndEntities() {
                         if (dimensionManager instanceof LBKeyedPoolThreadManager) {
                             ((LBKeyedPoolThreadManager) dimensionManager).setLoadFunction(id, () -> {
                                 WorldServer worldObj = DimensionManager.getWorld(id);
+                                // TODO: Fine tune this.
                                 return (worldObj.playerEntities.size() / 10d)
                                     + (ForgeChunkManager.getPersistentChunksFor(worldObj)
                                         .size() / 50d)
-                                    + (worldObj.getLoadedEntityList()
-                                        .size() / 100d);
+                                    + (worldObj.loadedTileEntityList.size() / 80d)
+                                    + (worldObj.loadedEntityList.size() / 100d);
                             });
                         }
                     }

src/test/java/com/gamma/spool/util/DistanceThreadingUtilTest.java

@@ -8,7 +8,6 @@
 
 import net.minecraft.world.ChunkCoordIntPair;
 
-import org.jctools.maps.NonBlockingHashSet;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -21,6 +20,8 @@
 import com.gamma.spool.util.distance.DistanceThreadingUtil;
 
 import it.unimi.dsi.fastutil.longs.Long2IntMap;
+import it.unimi.dsi.fastutil.longs.LongArraySet;
+import it.unimi.dsi.fastutil.longs.LongSet;
 
 /**
  * Tests for the {@link DistanceThreadingUtil} class.
@@ -119,7 +120,7 @@ public void testFloodFillEmptyChunksSequential() {
         DistanceThreadingConfig.parallelizeStreams = false;
 
         // Create an empty chunks set
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
 
         // Create a seed chunk hash
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
@@ -147,7 +148,7 @@ public void testFloodFillEmptyChunksParallel() {
         DistanceThreadingConfig.parallelizeStreams = true;
 
         // Create an empty chunks set
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
 
         // Create a seed chunk hash
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
@@ -175,7 +176,7 @@ public void testFloodFillSingleChunkSequential() {
         DistanceThreadingConfig.parallelizeStreams = false;
 
         // Create a chunks set with a single chunk
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long chunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(chunkHash);
 
@@ -202,7 +203,7 @@ public void testFloodFillSingleChunkParallel() {
         DistanceThreadingConfig.parallelizeStreams = true;
 
         // Create a chunks set with a single chunk
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long chunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(chunkHash);
 
@@ -229,7 +230,7 @@ public void testFloodFillConnectedChunksSequential() {
         DistanceThreadingConfig.parallelizeStreams = false;
 
         // Create a chunk set with connected chunks
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(seedChunkHash);
 
@@ -284,7 +285,7 @@ public void testFloodFillConnectedChunksParallel() {
         DistanceThreadingConfig.parallelizeStreams = true;
 
         // Create a chunks set with connected chunks
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(seedChunkHash);
 
@@ -339,7 +340,7 @@ public void testFloodFillDisconnectedChunksSequential() {
         DistanceThreadingConfig.parallelizeStreams = false;
 
         // Create a chunks set with disconnected chunks
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(seedChunkHash);
 
@@ -380,7 +381,7 @@ public void testFloodFillDisconnectedChunksParallel() {
         DistanceThreadingConfig.parallelizeStreams = true;
 
         // Create a chunks set with disconnected chunks
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(seedChunkHash);
 
@@ -420,7 +421,7 @@ public void testFloodFillManyConnectedChunksSequential() {
         DistanceThreadingUtil.init(keyedPool);
 
         // Create a chunks set with connected chunks
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(seedChunkHash);
 
@@ -474,7 +475,7 @@ public void testFloodFillManyConnectedChunksParallel() {
         DistanceThreadingConfig.parallelizeStreams = true;
 
         // Create a chunks set with connected chunks
-        NonBlockingHashSet<Long> chunks = new NonBlockingHashSet<>();
+        LongSet chunks = new LongArraySet();
         long seedChunkHash = ChunkCoordIntPair.chunkXZ2Int(0, 0);
         chunks.add(seedChunkHash);