diff --git a/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java b/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java index bcbc7708..61cd01b9 100644 --- a/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java +++ b/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java @@ -222,7 +222,7 @@ public class Datahandler { hlStatsMessages.put(str, hlStatsMessages.size()); } } - int capacity = 1500; + int capacity = 5500; hlStatsMessages.keySet().forEach(str -> { if (!str.startsWith("!") && MessageResponseHandler.getStr().values().size() < capacity) { String orElse = strCacheLocal.values().parallelStream().filter(e -> e.equals(str)).findAny().orElse(null); @@ -319,7 +319,20 @@ public class Datahandler { SentimentValueCache sentimentCacheStr = sentimentCachingMap.getOrDefault(str, null); List smxReturnList = new ArrayList(); ExecutorService smxService = Executors.newFixedThreadPool(6); + List randomIterationComparision = new ArrayList(); + int iteratecap = strCacheLocal.size() > 150 ? strCacheLocal.size() - 150 : strCacheLocal.size(); + int iterator = ThreadLocalRandom.current().nextInt(0, iteratecap); + int iterated = 0; for (String str1 : strCacheLocal.values()) { + if (iterated >= iterator && iterated < iterator + 150) { + randomIterationComparision.add(str1); + } + if (iterated > iterator + 150) { + break; + } + iterated++; + } + for (String str1 : randomIterationComparision) { if (!str.equals(str1)) { SimilarityMatrix SMXInit = new SimilarityMatrix(str, str1); SentimentValueCache sentimentCacheStr1 = sentimentCachingMap.getOrDefault(str1, null); @@ -340,6 +353,7 @@ public class Datahandler { SimilarityMatrix SMX = future.get(); if (SMX != null) { smxReturnList.add(SMX); + //System.out.println("added SMX: " + SMX.getPrimaryString() + "\n" + SMX.getSecondaryString() + "\n\n"); } } catch (InterruptedException | ExecutionException ex) { //System.out.println("failed future get"); @@ -783,7 +797,7 @@ public class Datahandler { // System.out.println("iterator: " + annCollector.i + "\nstr size: " + str.size() + "\n"); } try { - Thread.sleep(4000); + Thread.sleep(10000); } catch (InterruptedException ex) { Logger.getLogger(Datahandler.class.getName()).log(Level.SEVERE, null, ex); }