clarified messages streaming (again, amending 5ea3ed3c52b3): avoid too many small messages stacking up, e.g. when loading HOL-Analysis.Analysis.thy into Isabelle/jEdit;
authorwenzelm
Wed, 04 Dec 2019 19:40:22 +0100
changeset 71231 dafa5fce70f1
parent 71229 be2c2bfa54a0
child 71232 7b9ff966974f
clarified messages streaming (again, amending 5ea3ed3c52b3): avoid too many small messages stacking up, e.g. when loading HOL-Analysis.Analysis.thy into Isabelle/jEdit;
src/Pure/Concurrent/consumer_thread.scala
--- a/src/Pure/Concurrent/consumer_thread.scala	Wed Dec 04 15:36:58 2019 +0100
+++ b/src/Pure/Concurrent/consumer_thread.scala	Wed Dec 04 19:40:22 2019 +0100
@@ -104,11 +104,7 @@
           }
         }
 
-        if (continue) {
-          val msgs1 = msgs.drop(reqs.length)
-          val msgs2 = mailbox.receive(timeout = Some(Time.zero))
-          main_loop(msgs1 ::: msgs2)
-        }
+        if (continue) main_loop(msgs.drop(reqs.length))
         else robust_finish()
     }