< prev index next >

src/hotspot/share/gc/g1/g1ConcurrentRefineThread.hpp

Print this page
rev 47675 : [mq]: 8149127-rename-concurrentrefine-a
rev 47676 : imported patch 8149127-rename-concurrentrefine-b
rev 47677 : [mq]: 8149127-rename-concurrentrefine-b-stefanj-review
rev 47680 : [mq]: 8190426-lazy-init-refinement-threads

*** 41,85 **** double _vtime_start; // Initial virtual time. double _vtime_accum; // Accumulated virtual time. uint _worker_id; uint _worker_id_offset; - // The refinement threads collection is linked list. A predecessor can activate a successor - // when the number of the rset update buffer crosses a certain threshold. A successor - // would self-deactivate when the number of the buffers falls below the threshold. bool _active; - G1ConcurrentRefineThread* _next; Monitor* _monitor; G1ConcurrentRefine* _cr; - // This thread's activation/deactivation thresholds - size_t _activation_threshold; - size_t _deactivation_threshold; - void wait_for_completed_buffers(); void set_active(bool x) { _active = x; } bool is_active(); ! void activate(); void deactivate(); bool is_primary() { return (_worker_id == 0); } void run_service(); void stop_service(); - public: ! // Constructor ! G1ConcurrentRefineThread(G1ConcurrentRefine* cr, G1ConcurrentRefineThread* next, ! uint worker_id_offset, uint worker_id, ! size_t activate, size_t deactivate); ! void update_thresholds(size_t activate, size_t deactivate); ! size_t activation_threshold() const { return _activation_threshold; } // Total virtual time so far. double vtime_accum() { return _vtime_accum; } - - G1ConcurrentRefine* cr() { return _cr; } }; #endif // SHARE_VM_GC_G1_G1CONCURRENTREFINETHREAD_HPP --- 41,71 ---- double _vtime_start; // Initial virtual time. double _vtime_accum; // Accumulated virtual time. uint _worker_id; uint _worker_id_offset; bool _active; Monitor* _monitor; G1ConcurrentRefine* _cr; void wait_for_completed_buffers(); void set_active(bool x) { _active = x; } bool is_active(); ! // Deactivate this thread. void deactivate(); bool is_primary() { return (_worker_id == 0); } void run_service(); void stop_service(); public: ! G1ConcurrentRefineThread(G1ConcurrentRefine* cg1r, uint worker_id); ! // Activate this thread. ! void activate(); // Total virtual time so far. double vtime_accum() { return _vtime_accum; } }; #endif // SHARE_VM_GC_G1_G1CONCURRENTREFINETHREAD_HPP
< prev index next >