< prev index next >

src/share/vm/gc/g1/concurrentG1RefineThread.cpp

Print this page
rev 10297 : [mq]: webrev.01

*** 105,123 **** DirtyCardQueueSet& dcqs = JavaThread::dirty_card_queue_set(); dcqs.set_process_completed(false); } } - void ConcurrentG1RefineThread::run() { - initialize_in_thread(); - wait_for_universe_init(); - - run_service(); - - terminate(); - } - void ConcurrentG1RefineThread::run_service() { _vtime_start = os::elapsedVTime(); while (!_should_terminate) { // Wait for work --- 105,114 ----
*** 164,189 **** } log_debug(gc, refine)("Stopping %d", _worker_id); } - void ConcurrentG1RefineThread::stop() { - // it is ok to take late safepoints here, if needed - { - MutexLockerEx mu(Terminator_lock); - _should_terminate = true; - } - - stop_service(); - - { - MutexLockerEx mu(Terminator_lock); - while (!_has_terminated) { - Terminator_lock->wait(); - } - } - } - void ConcurrentG1RefineThread::stop_service() { MutexLockerEx x(_monitor, Mutex::_no_safepoint_check_flag); _monitor->notify(); } --- 155,163 ----
< prev index next >