< prev index next >
src/hotspot/share/gc/parallel/psParallelCompact.cpp
Print this page
rev 57840 : imported patch 8215297-remove-ptt
rev 57842 : imported patch 8238220-rename-owsttaskterminator
rev 57843 : [mq]: 8238160-parallel-gc-task-queue-naming
@@ -2180,11 +2180,11 @@
public:
MarkFromRootsTask(uint active_workers) :
AbstractGangTask("MarkFromRootsTask"),
_strong_roots_scope(active_workers),
_subtasks(),
- _terminator(active_workers, ParCompactionManager::stack_array()),
+ _terminator(active_workers, ParCompactionManager::oop_task_queues()),
_active_workers(active_workers) {
_subtasks.set_n_threads(active_workers);
_subtasks.set_n_tasks(ParallelRootType::sentinel);
}
@@ -2212,11 +2212,11 @@
public:
PCRefProcTask(ProcessTask& task, uint ergo_workers) :
AbstractGangTask("PCRefProcTask"),
_task(task),
_ergo_workers(ergo_workers),
- _terminator(_ergo_workers, ParCompactionManager::stack_array()) {
+ _terminator(_ergo_workers, ParCompactionManager::oop_task_queues()) {
}
virtual void work(uint worker_id) {
ParallelScavengeHeap* heap = ParallelScavengeHeap::heap();
assert(ParallelScavengeHeap::heap()->is_gc_active(), "called outside gc");
@@ -2628,11 +2628,11 @@
public:
UpdateDensePrefixAndCompactionTask(TaskQueue& tq, uint active_workers) :
AbstractGangTask("UpdateDensePrefixAndCompactionTask"),
_tq(tq),
- _terminator(active_workers, ParCompactionManager::region_array()),
+ _terminator(active_workers, ParCompactionManager::region_task_queues()),
_active_workers(active_workers) {
}
virtual void work(uint worker_id) {
ParCompactionManager* cm = ParCompactionManager::gc_thread_compaction_manager(worker_id);
< prev index next >