merged

--- a/src/Pure/Concurrent/consumer_thread.scala	Wed Dec 04 18:28:24 2019 +0100
+++ b/src/Pure/Concurrent/consumer_thread.scala	Wed Dec 04 19:55:30 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()
     }