< prev index next >
src/share/vm/gc/parallel/gcTaskManager.cpp
Print this page
*** 28,37 ****
--- 28,38 ----
#include "gc/shared/adaptiveSizePolicy.hpp"
#include "gc/shared/gcId.hpp"
#include "logging/log.hpp"
#include "memory/allocation.hpp"
#include "memory/allocation.inline.hpp"
+ #include "memory/resourceArea.hpp"
#include "runtime/mutex.hpp"
#include "runtime/mutexLocker.hpp"
#include "runtime/orderAccess.inline.hpp"
//
*** 402,417 ****
}
_thread = NEW_C_HEAP_ARRAY(GCTaskThread*, workers(), mtGC);
for (uint t = 0; t < workers(); t += 1) {
set_thread(t, GCTaskThread::create(this, t, processor_assignment[t]));
}
! if (TraceGCTaskThread) {
! tty->print("GCTaskManager::initialize: distribution:");
for (uint t = 0; t < workers(); t += 1) {
! tty->print(" %u", processor_assignment[t]);
}
! tty->cr();
}
FREE_C_HEAP_ARRAY(uint, processor_assignment);
}
reset_busy_workers();
set_unblocked();
--- 403,421 ----
}
_thread = NEW_C_HEAP_ARRAY(GCTaskThread*, workers(), mtGC);
for (uint t = 0; t < workers(); t += 1) {
set_thread(t, GCTaskThread::create(this, t, processor_assignment[t]));
}
! LogHandle(gc, task, thread) log;
! if (log.is_trace()) {
! ResourceMark rm;
! outputStream* out = log.trace_stream();
! out->print("GCTaskManager::initialize: distribution:");
for (uint t = 0; t < workers(); t += 1) {
! out->print(" %u", processor_assignment[t]);
}
! out->cr();
}
FREE_C_HEAP_ARRAY(uint, processor_assignment);
}
reset_busy_workers();
set_unblocked();
< prev index next >