Merge pull request #50 from hizumiaoba/release/v4.0.0-Beta

[delesterandomselector/DelesteRandomSelector.git] / src / com / ranfa / lib / ManualUpdateThreadImpl.java

diff --git a/src/com/ranfa/lib/ManualUpdateThreadImpl.java b/src/com/ranfa/lib/ManualUpdateThreadImpl.java
index 5fdf858..2b526d4 100644 (file)
--- a/src/com/ranfa/lib/ManualUpdateThreadImpl.java
+++ b/src/com/ranfa/lib/ManualUpdateThreadImpl.java
@@ -9,13 +9,17 @@ import java.util.function.BiConsumer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.ranfa.lib.concurrent.CountedThreadFactory;
+import com.ranfa.lib.database.Scraping;
+import com.ranfa.lib.database.Song;
+
 public class ManualUpdateThreadImpl implements Runnable {
 
        //Declare flag
        private static boolean flag = true;
 
        //Declare Executor service
-       private Executor executor = Executors.newWorkStealingPool();
+       private Executor executor = Executors.newCachedThreadPool(new CountedThreadFactory(() -> "DRS", "ManualUpdateThread"));
        private BiConsumer<ArrayList<Song>, ArrayList<Song>> updateConsumer = (list1, list2) -> {
                this.logger.info("Checking database updates...");
                if(list1.size() > list2.size()) {