equal
deleted
inserted
replaced
25 #include "precompiled.hpp" |
25 #include "precompiled.hpp" |
26 #include "gc/parallel/gcTaskManager.hpp" |
26 #include "gc/parallel/gcTaskManager.hpp" |
27 #include "gc/parallel/gcTaskThread.hpp" |
27 #include "gc/parallel/gcTaskThread.hpp" |
28 #include "gc/shared/gcId.hpp" |
28 #include "gc/shared/gcId.hpp" |
29 #include "gc/shared/workerManager.hpp" |
29 #include "gc/shared/workerManager.hpp" |
|
30 #include "gc/shared/workerPolicy.hpp" |
30 #include "logging/log.hpp" |
31 #include "logging/log.hpp" |
31 #include "logging/logStream.hpp" |
32 #include "logging/logStream.hpp" |
32 #include "memory/allocation.hpp" |
33 #include "memory/allocation.hpp" |
33 #include "memory/allocation.inline.hpp" |
34 #include "memory/allocation.inline.hpp" |
34 #include "memory/resourceArea.hpp" |
35 #include "memory/resourceArea.hpp" |
492 } |
493 } |
493 } |
494 } |
494 |
495 |
495 void GCTaskManager::set_active_gang() { |
496 void GCTaskManager::set_active_gang() { |
496 _active_workers = |
497 _active_workers = |
497 AdaptiveSizePolicy::calc_active_workers(workers(), |
498 WorkerPolicy::calc_active_workers(workers(), |
498 active_workers(), |
499 active_workers(), |
499 Threads::number_of_non_daemon_threads()); |
500 Threads::number_of_non_daemon_threads()); |
500 |
501 |
501 assert(!all_workers_active() || active_workers() == ParallelGCThreads, |
502 assert(!all_workers_active() || active_workers() == ParallelGCThreads, |
502 "all_workers_active() is incorrect: " |
503 "all_workers_active() is incorrect: " |
503 "active %d ParallelGCThreads %u", active_workers(), |
504 "active %d ParallelGCThreads %u", active_workers(), |
504 ParallelGCThreads); |
505 ParallelGCThreads); |