UNLOZE/projects-jenz
11
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

just badly recreating threadpool in case thread is stuck

Browse Source
This commit is contained in:
jenz 2023-02-10 23:53:30 +01:00
parent 845c6dd0c0
commit 4c098cd683
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java
View File

@ -27,7 +27,7 @@ import java.util.regex.Pattern;
public class Datahandler { public class Datahandler {
private ExecutorService pool = Executors.newFixedThreadPool(7); private ExecutorService pool = Executors.newFixedThreadPool(4);
private CompletionService completionService = new ExecutorCompletionService(pool); private CompletionService completionService = new ExecutorCompletionService(pool);
private HashMap<String, Annotation> pipelineAnnotationCache; private HashMap<String, Annotation> pipelineAnnotationCache;
private HashMap<String, Annotation> pipelineSentimentAnnotationCache; private HashMap<String, Annotation> pipelineSentimentAnnotationCache;
@ -716,10 +716,18 @@ public class Datahandler {
} }
} catch (InterruptedException e) { } catch (InterruptedException e) {
//throw new RuntimeException(e); //throw new RuntimeException(e);
--pending; pending = 0;
System.out.printf(Arrays.toString(e.getStackTrace()));
pool.shutdown();
pool = Executors.newFixedThreadPool(4);
completionService = new ExecutorCompletionService(pool);
} catch (ExecutionException e) { } catch (ExecutionException e) {
//throw new RuntimeException(e); //throw new RuntimeException(e);
--pending; pending = 0;
System.out.printf(Arrays.toString(e.getStackTrace()));
pool.shutdown();
pool = Executors.newFixedThreadPool(4);
completionService = new ExecutorCompletionService(pool);
} }
} }