equal
deleted
inserted
replaced
41 #include "gc/shared/gcTrace.hpp" |
41 #include "gc/shared/gcTrace.hpp" |
42 #include "gc/shared/gcTraceTime.inline.hpp" |
42 #include "gc/shared/gcTraceTime.inline.hpp" |
43 #include "gc/shared/isGCActiveMark.hpp" |
43 #include "gc/shared/isGCActiveMark.hpp" |
44 #include "gc/shared/referencePolicy.hpp" |
44 #include "gc/shared/referencePolicy.hpp" |
45 #include "gc/shared/referenceProcessor.hpp" |
45 #include "gc/shared/referenceProcessor.hpp" |
|
46 #include "gc/shared/referenceProcessorPhaseTimes.hpp" |
46 #include "gc/shared/spaceDecorator.hpp" |
47 #include "gc/shared/spaceDecorator.hpp" |
47 #include "gc/shared/weakProcessor.hpp" |
48 #include "gc/shared/weakProcessor.hpp" |
48 #include "memory/resourceArea.hpp" |
49 #include "memory/resourceArea.hpp" |
49 #include "logging/log.hpp" |
50 #include "logging/log.hpp" |
50 #include "oops/access.inline.hpp" |
51 #include "oops/access.inline.hpp" |
158 GCTaskManager* manager = ParallelScavengeHeap::gc_task_manager(); |
159 GCTaskManager* manager = ParallelScavengeHeap::gc_task_manager(); |
159 for(uint i=0; i < manager->active_workers(); i++) { |
160 for(uint i=0; i < manager->active_workers(); i++) { |
160 q->enqueue(new PSRefProcTaskProxy(task, i)); |
161 q->enqueue(new PSRefProcTaskProxy(task, i)); |
161 } |
162 } |
162 ParallelTaskTerminator terminator(manager->active_workers(), |
163 ParallelTaskTerminator terminator(manager->active_workers(), |
163 (TaskQueueSetSuper*) PSPromotionManager::stack_array_depth()); |
164 (TaskQueueSetSuper*) PSPromotionManager::stack_array_depth()); |
164 if (task.marks_oops_alive() && manager->active_workers() > 1) { |
165 if (task.marks_oops_alive() && manager->active_workers() > 1) { |
165 for (uint j = 0; j < manager->active_workers(); j++) { |
166 for (uint j = 0; j < manager->active_workers(); j++) { |
166 q->enqueue(new StealTask(&terminator)); |
167 q->enqueue(new StealTask(&terminator)); |
167 } |
168 } |
168 } |
169 } |