You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nlpcraft.apache.org by ar...@apache.org on 2020/09/06 02:44:00 UTC

[incubator-nlpcraft] 01/03: WIP.

This is an automated email from the ASF dual-hosted git repository.

aradzinski pushed a commit to branch NLPCRAFT-41
in repository https://gitbox.apache.org/repos/asf/incubator-nlpcraft.git

commit 4108c6598c2b0a5e2d691f48893995bd50ff4b50
Author: Aaron Radzinski <ar...@datalingvo.com>
AuthorDate: Sat Sep 5 19:40:53 2020 -0700

    WIP.
---
 .../scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala     | 2 ++
 .../apache/nlpcraft/probe/mgrs/inspections/inspectors/NCInspector.scala | 2 ++
 .../org/apache/nlpcraft/probe/mgrs/nlp/NCProbeEnrichmentManager.scala   | 2 +-
 3 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala
index 5510e94..f2c333e 100644
--- a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala
+++ b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/cmd/NCCommandManager.scala
@@ -58,7 +58,9 @@ object NCCommandManager extends NCService {
         super.stop()
 
         NCUtils.shutdownPools(pool)
+
         executor = null
+        pool = null
     }
     
     /**
diff --git a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/inspections/inspectors/NCInspector.scala b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/inspections/inspectors/NCInspector.scala
index e175c34..e2a6852 100644
--- a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/inspections/inspectors/NCInspector.scala
+++ b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/inspections/inspectors/NCInspector.scala
@@ -56,6 +56,8 @@ private[inspections] trait NCInspector extends NCService {
             super.stop(parent)
 
             NCUtils.shutdownPools(pool)
+
             executor = null
+            pool = null
         }
 }
diff --git a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/nlp/NCProbeEnrichmentManager.scala b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/nlp/NCProbeEnrichmentManager.scala
index 7d36ed5..8c86dd6 100644
--- a/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/nlp/NCProbeEnrichmentManager.scala
+++ b/nlpcraft/src/main/scala/org/apache/nlpcraft/probe/mgrs/nlp/NCProbeEnrichmentManager.scala
@@ -85,7 +85,6 @@ object NCProbeEnrichmentManager extends NCService with NCOpenCensusModelStats {
         embeddedCbs = mutable.HashSet.empty[EMBEDDED_CB]
 
         pool = Executors.newFixedThreadPool(8 * Runtime.getRuntime.availableProcessors())
-
         executor = ExecutionContext.fromExecutor(pool)
 
         super.start()
@@ -100,6 +99,7 @@ object NCProbeEnrichmentManager extends NCService with NCOpenCensusModelStats {
         U.shutdownPools(pool)
 
         executor = null
+        pool = null
 
         super.stop()
     }