< prev index next >

src/hotspot/share/gc/g1/g1ConcurrentRefine.cpp

Print this page
rev 47863 : imported patch 8190426-lazy-init-refinement-threads
rev 47864 : [mq]: 8190426-sangheon-review
rev 47865 : [mq]: 8190426-stefanj-review

*** 102,112 **** if (thread_to_activate == NULL) { // Still need to create the thread... _threads[worker_id] = create_refinement_thread(worker_id, false); thread_to_activate = _threads[worker_id]; } ! if (thread_to_activate != NULL) { thread_to_activate->activate(); } } void G1ConcurrentRefineThreadControl::print_on(outputStream* st) const { --- 102,112 ---- if (thread_to_activate == NULL) { // Still need to create the thread... _threads[worker_id] = create_refinement_thread(worker_id, false); thread_to_activate = _threads[worker_id]; } ! if (thread_to_activate != NULL && !thread_to_activate->is_active()) { thread_to_activate->activate(); } } void G1ConcurrentRefineThreadControl::print_on(outputStream* st) const {
*** 416,426 **** uint G1ConcurrentRefine::worker_id_offset() { return DirtyCardQueueSet::num_par_ids(); } void G1ConcurrentRefine::maybe_activate_more_threads(uint worker_id, size_t num_cur_buffers) { ! if (activation_threshold(worker_id + 1) > num_cur_buffers) { _thread_control.maybe_activate_next(worker_id); } } bool G1ConcurrentRefine::do_refinement_step(uint worker_id) { --- 416,426 ---- uint G1ConcurrentRefine::worker_id_offset() { return DirtyCardQueueSet::num_par_ids(); } void G1ConcurrentRefine::maybe_activate_more_threads(uint worker_id, size_t num_cur_buffers) { ! if (num_cur_buffers > activation_threshold(worker_id + 1)) { _thread_control.maybe_activate_next(worker_id); } } bool G1ConcurrentRefine::do_refinement_step(uint worker_id) {
< prev index next >