44 _stack_closure(this),
45 _cld_closure(mark_closure(), ClassLoaderData::_claim_stw_fullgc_mark),
46 _mark_stats_cache(mark_stats, G1RegionMarkStatsCache::RegionMarkStatsCacheSize) {
47 ClassLoaderDataGraph::verify_claimed_marks_cleared(ClassLoaderData::_claim_stw_fullgc_mark);
48 _mark_stats_cache.reset();
49 }
50
51 G1FullGCMarker::~G1FullGCMarker() {
52 assert(is_task_queue_empty(), "Must be empty at this point");
53 }
54
55 void G1FullGCMarker::process_partial_array(PartialArrayState* state, bool stolen) {
56 // Access state before release by claim().
57 objArrayOop obj_array = objArrayOop(state->source());
58 PartialArraySplitter::Claim claim =
59 _partial_array_splitter.claim(state, task_queue(), stolen);
60 process_array_chunk(obj_array, claim._start, claim._end);
61 }
62
63 void G1FullGCMarker::start_partial_array_processing(objArrayOop obj) {
64 mark_closure()->do_klass(obj->klass());
65 // Don't push empty arrays to avoid unnecessary work.
66 size_t array_length = obj->length();
67 if (array_length > 0) {
68 size_t initial_chunk_size = _partial_array_splitter.start(task_queue(), obj, nullptr, array_length);
69 process_array_chunk(obj, 0, initial_chunk_size);
70 }
71 }
72
73 void G1FullGCMarker::complete_marking(G1ScannerTasksQueueSet* task_queues,
74 TaskTerminator* terminator) {
75 do {
76 process_marking_stacks();
77 ScannerTask stolen_task;
78 if (task_queues->steal(_worker_id, stolen_task)) {
79 dispatch_task(stolen_task, true);
80 }
81 } while (!is_task_queue_empty() || !terminator->offer_termination());
82 }
83
84 void G1FullGCMarker::flush_mark_stats_cache() {
|
44 _stack_closure(this),
45 _cld_closure(mark_closure(), ClassLoaderData::_claim_stw_fullgc_mark),
46 _mark_stats_cache(mark_stats, G1RegionMarkStatsCache::RegionMarkStatsCacheSize) {
47 ClassLoaderDataGraph::verify_claimed_marks_cleared(ClassLoaderData::_claim_stw_fullgc_mark);
48 _mark_stats_cache.reset();
49 }
50
51 G1FullGCMarker::~G1FullGCMarker() {
52 assert(is_task_queue_empty(), "Must be empty at this point");
53 }
54
55 void G1FullGCMarker::process_partial_array(PartialArrayState* state, bool stolen) {
56 // Access state before release by claim().
57 objArrayOop obj_array = objArrayOop(state->source());
58 PartialArraySplitter::Claim claim =
59 _partial_array_splitter.claim(state, task_queue(), stolen);
60 process_array_chunk(obj_array, claim._start, claim._end);
61 }
62
63 void G1FullGCMarker::start_partial_array_processing(objArrayOop obj) {
64 precond(obj->is_array_with_oops());
65 mark_closure()->do_klass(obj->klass());
66
67 if (obj->is_flatArray()) {
68 mark_closure()->do_klass(FlatArrayKlass::cast(obj->klass())->element_klass());
69 }
70
71 // Don't push empty arrays to avoid unnecessary work.
72 size_t array_length = obj->length();
73 if (array_length > 0) {
74 size_t initial_chunk_size = _partial_array_splitter.start(task_queue(), obj, nullptr, array_length);
75 process_array_chunk(obj, 0, initial_chunk_size);
76 }
77 }
78
79 void G1FullGCMarker::complete_marking(G1ScannerTasksQueueSet* task_queues,
80 TaskTerminator* terminator) {
81 do {
82 process_marking_stacks();
83 ScannerTask stolen_task;
84 if (task_queues->steal(_worker_id, stolen_task)) {
85 dispatch_task(stolen_task, true);
86 }
87 } while (!is_task_queue_empty() || !terminator->offer_termination());
88 }
89
90 void G1FullGCMarker::flush_mark_stats_cache() {
|