equal
deleted
inserted
replaced
152 |
152 |
153 // Check if we need to activate the next thread. |
153 // Check if we need to activate the next thread. |
154 if (_next != NULL && !_next->is_active() && curr_buffer_num > _next->_threshold) { |
154 if (_next != NULL && !_next->is_active() && curr_buffer_num > _next->_threshold) { |
155 _next->activate(); |
155 _next->activate(); |
156 } |
156 } |
157 } while (dcqs.apply_closure_to_completed_buffer(_refine_closure, _worker_id + _worker_id_offset, cg1r()->green_zone())); |
157 } while (dcqs.apply_closure_to_completed_buffer(_refine_closure, |
|
158 _worker_id + _worker_id_offset, |
|
159 cg1r()->green_zone(), |
|
160 false /* during_pause */)); |
158 |
161 |
159 // We can exit the loop above while being active if there was a yield request. |
162 // We can exit the loop above while being active if there was a yield request. |
160 if (is_active()) { |
163 if (is_active()) { |
161 deactivate(); |
164 deactivate(); |
162 } |
165 } |