Mercurial Mercurial > repos > isabelle / changeset
summary | shortlog | changelog | graph | tags | bookmarks | branches | files | changeset | raw | gz | help
Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
more robust executor policy after shutdown;
authorwenzelm
Tue, 29 Sep 2020 15:30:47 +0200
changeset 72336 41a4352c5240
parent 72335 b8708212bdd5
child 72337 4075560b3d5c
more robust executor policy after shutdown;
src/HOL/Tools/Nitpick/kodkod.scala file | annotate | diff | comparison | revisions 
--- a/src/HOL/Tools/Nitpick/kodkod.scala	Tue Sep 29 15:05:37 2020 +0200
+++ b/src/HOL/Tools/Nitpick/kodkod.scala	Tue Sep 29 15:30:47 2020 +0200
@@ -8,7 +8,7 @@
 
 import isabelle._
 
-import java.util.concurrent.Executors
+import java.util.concurrent.{TimeUnit, LinkedBlockingQueue, ThreadPoolExecutor}
 
 import org.antlr.runtime.{ANTLRInputStream, RecognitionException}
 import de.tum.in.isabelle.Kodkodi.{Context, KodkodiLexer, KodkodiParser}
@@ -46,8 +46,10 @@
     /* executor */
 
     val pool_size = if (max_threads == 0) Isabelle_Thread.max_threads() else max_threads
+    val executor: ThreadPoolExecutor =
+      new ThreadPoolExecutor(pool_size, pool_size, 0L, TimeUnit.MILLISECONDS,
+        new LinkedBlockingQueue[Runnable], new ThreadPoolExecutor.CallerRunsPolicy)
 
-    val executor = Executors.newFixedThreadPool(pool_size)
     val executor_killed = Synchronized(false)
     def executor_kill(): Unit =
       executor_killed.change(b =>
isabelle