< 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,2190 **** public: MarkFromRootsTask(uint active_workers) : AbstractGangTask("MarkFromRootsTask"), _strong_roots_scope(active_workers), _subtasks(), ! _terminator(active_workers, ParCompactionManager::stack_array()), _active_workers(active_workers) { _subtasks.set_n_threads(active_workers); _subtasks.set_n_tasks(ParallelRootType::sentinel); } --- 2180,2190 ---- public: MarkFromRootsTask(uint active_workers) : AbstractGangTask("MarkFromRootsTask"), _strong_roots_scope(active_workers), _subtasks(), ! _terminator(active_workers, ParCompactionManager::oop_task_queues()), _active_workers(active_workers) { _subtasks.set_n_threads(active_workers); _subtasks.set_n_tasks(ParallelRootType::sentinel); }
*** 2212,2222 **** public: PCRefProcTask(ProcessTask& task, uint ergo_workers) : AbstractGangTask("PCRefProcTask"), _task(task), _ergo_workers(ergo_workers), ! _terminator(_ergo_workers, ParCompactionManager::stack_array()) { } virtual void work(uint worker_id) { ParallelScavengeHeap* heap = ParallelScavengeHeap::heap(); assert(ParallelScavengeHeap::heap()->is_gc_active(), "called outside gc"); --- 2212,2222 ---- public: PCRefProcTask(ProcessTask& task, uint ergo_workers) : AbstractGangTask("PCRefProcTask"), _task(task), _ergo_workers(ergo_workers), ! _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,2638 **** public: UpdateDensePrefixAndCompactionTask(TaskQueue& tq, uint active_workers) : AbstractGangTask("UpdateDensePrefixAndCompactionTask"), _tq(tq), ! _terminator(active_workers, ParCompactionManager::region_array()), _active_workers(active_workers) { } virtual void work(uint worker_id) { ParCompactionManager* cm = ParCompactionManager::gc_thread_compaction_manager(worker_id); --- 2628,2638 ---- public: UpdateDensePrefixAndCompactionTask(TaskQueue& tq, uint active_workers) : AbstractGangTask("UpdateDensePrefixAndCompactionTask"), _tq(tq), ! _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 >