src/share/vm/gc/shared/taskqueue.cpp

rev 12669 : [mq]: degenerating-marking.patch

@@ -224,11 +224,14 @@
       }
 
 #ifdef TRACESPINNING
       _total_peeks++;
 #endif
-      if (peek_in_queue_set() ||
+      if (terminator != NULL && terminator->should_force_termination()) {
+        return true;
+      }
+      if (peek_in_queue_set()) ||
           (terminator != NULL && terminator->should_exit_termination())) {
         Atomic::dec((int *)&_offered_termination);
         assert(_offered_termination < _n_threads, "Invariant");
         return false;
       }