--- old/src/share/vm/gc_implementation/parNew/parNewGeneration.cpp 2015-03-26 12:07:04.081783809 +0300 +++ new/src/share/vm/gc_implementation/parNew/parNewGeneration.cpp 2015-03-26 12:07:03.909697818 +0300 @@ -310,7 +310,7 @@ inline ParScanThreadState& thread_state(int i); void trace_promotion_failed(const YoungGCTracer* gc_tracer); - void reset(int active_workers, bool promotion_failed); + void reset(uint active_workers, bool promotion_failed); void flush(); #if TASKQUEUE_STATS @@ -367,7 +367,7 @@ } } -void ParScanThreadStateSet::reset(int active_threads, bool promotion_failed) +void ParScanThreadStateSet::reset(uint active_threads, bool promotion_failed) { _term.reset_for_reuse(active_threads); if (promotion_failed) { @@ -585,7 +585,7 @@ // Reset the terminator for the given number of // active threads. -void ParNewGenTask::set_for_termination(int active_workers) { +void ParNewGenTask::set_for_termination(uint active_workers) { _state_set->reset(active_workers, _gen->promotion_failed()); // Should the heap be passed in? There's only 1 for now so // grab it instead. @@ -770,7 +770,7 @@ private: virtual void work(uint worker_id); - virtual void set_for_termination(int active_workers) { + virtual void set_for_termination(uint active_workers) { _state_set.terminator()->reset_for_reuse(active_workers); } private: @@ -920,7 +920,7 @@ AdaptiveSizePolicy* size_policy = gch->gen_policy()->size_policy(); FlexibleWorkGang* workers = gch->workers(); assert(workers != NULL, "Need workgang for parallel work"); - int active_workers = + uint active_workers = AdaptiveSizePolicy::calc_active_workers(workers->total_workers(), workers->active_workers(), Threads::number_of_non_daemon_threads()); @@ -957,7 +957,7 @@ gch->save_marks(); assert(workers != NULL, "Need parallel worker threads."); - int n_workers = active_workers; + uint n_workers = active_workers; // Set the correct parallelism (number of queues) in the reference processor ref_processor()->set_active_mt_degree(n_workers);