OpenJDK17-JVM源码阅读-ZGC-并发标记

1、ZGC简介

1.1 介绍

ZGC 是一款低延迟的垃圾回收器，是 Java 垃圾收集技术的最前沿，理解了 ZGC，那么便可以说理解了 java 最前沿的垃圾收集技术。
从 JDK11 中作为试验特性推出以来，ZGC 一直在不停地发展中。
从 JDK14 开始，ZGC 开始支持 Windows。
在 JDK15 中，ZGC 不再是实验功能，可以正式投入生产使用了。
在最新的 JDK 开源库中，已经出现了分代收集的 ZGC 代码，预计不久的将来会正式发布，到时相信 ZGC 各项表现将会更加优秀。

图1 分代收集的ZGC
如上图，JDK21 中已经有了分代 ZGC 的 Feature。
1.2 ZGC 特征

• 低延迟
  
• 大容量堆
  
• 染色指针
  
• 读屏障
  

1.3 垃圾收集阶段


图2 ZGC 运作过程
如上图，主要有以下几个阶段，初始标记、并发标记/并发重映射、并发预备重分配、初始重分配、并发重分配，本次主要分析的就是”并发标记/并发重映射“部分源代码。
1.4 带着问题去读源码

• ZGC 是如何在指针上标记的
  
• ZGC 三色标记的过程
  
• ZGC 只用了读屏障是如何防止漏标的
  
• ZGC 标记过程中的指针自愈过程
  
• ZGC 并发标记中的并发重映射过程
  

2、源码

2.1 入口

整个 ZGC 的源码入口是 ZDriver::gc 函数

1. void ZDriver::gc(const ZDriverRequest& request) {
2.   ZDriverGCScope scope(request);
4.   // Phase 1: Pause Mark Start
5.   pause_mark_start();
7.   // Phase 2: Concurrent Mark
8.   concurrent(mark);
10.   // Phase 3: Pause Mark End
11.   while (!pause_mark_end()) {
12.     // Phase 3.5: Concurrent Mark Continue
13.     concurrent(mark_continue);
14.   }
16.   // Phase 4: Concurrent Mark Free
17.   concurrent(mark_free);
19.   // Phase 5: Concurrent Process Non-Strong References
20.   concurrent(process_non_strong_references);
22.   // Phase 6: Concurrent Reset Relocation Set
23.   concurrent(reset_relocation_set);
25.   // Phase 7: Pause Verify
26.   pause_verify();
28.   // Phase 8: Concurrent Select Relocation Set
29.   concurrent(select_relocation_set);
31.   // Phase 9: Pause Relocate Start
32.   pause_relocate_start();
34.   // Phase 10: Concurrent Relocate
35.   concurrent(relocate);
36. }

复制代码

其中，concurrent() 是一个宏定义

1. // Macro to execute a termination check after a concurrent phase. Note
2. // that it's important that the termination check comes after the call
3. // to the function f, since we can't abort between pause_relocate_start()
4. // and concurrent_relocate(). We need to let concurrent_relocate() call
5. // abort_page() on the remaining entries in the relocation set.
6. #define concurrent(f)                 \
7.   do {                                \
8.     concurrent_##f();                 \
9.     if (should_terminate()) {         \
10.       return;                         \
11.     }                                 \
12.   } while (false)

复制代码

于是我们可以知道并发标记的函数是 concurrent_mark

1. void ZDriver::concurrent_mark() {
2.   ZStatTimer timer(ZPhaseConcurrentMark);
3.   ZBreakpoint::at_after_marking_started();
4.   //开始对整个堆进行标记
5.   ZHeap::heap()->mark(true /* initial */);
6.   ZBreakpoint::at_before_marking_completed();
7. }

复制代码

2.2 并发标记过程

2.2.1 并发标记

接下来看 ZHeap::heap()->mark

1. void ZHeap::mark(bool initial) {
2.   _mark.mark(initial);
3. }

复制代码

再往下

1. void ZMark::mark(bool initial) {
2.   if (initial) {
3.     ZMarkRootsTask task(this);
4.     _workers->run(&task);
5.   }
7.   ZMarkTask task(this);
8.   _workers->run(&task);
9. }

复制代码

这里用了一个任务框架，执行任务逻辑在 ZMarkTask 里

1. class ZMarkTask : public ZTask {
2. private:
3.   ZMark* const   _mark;
4.   const uint64_t _timeout_in_micros;
6. public:
7.   ZMarkTask(ZMark* mark, uint64_t timeout_in_micros = 0) :
8.       ZTask("ZMarkTask"),
9.       _mark(mark),
10.       _timeout_in_micros(timeout_in_micros) {
11.     _mark->prepare_work();
12.   }
14.   ~ZMarkTask() {
15.     _mark->finish_work();
16.   }
18.   virtual void work() {
19.     _mark->work(_timeout_in_micros);
20.   }
21. };

复制代码

这里具体执行的函数是 work，往下看 _mark->work

1. void ZMark::work(uint64_t timeout_in_micros) {
2.   ZMarkCache cache(_stripes.nstripes());
3.   ZMarkStripe* const stripe = _stripes.stripe_for_worker(_nworkers, ZThread::worker_id());
4.   ZMarkThreadLocalStacks* const stacks = ZThreadLocalData::stacks(Thread::current());
6.   if (timeout_in_micros == 0) {
7.     work_without_timeout(&cache, stripe, stacks);
8.   } else {
9.     work_with_timeout(&cache, stripe, stacks, timeout_in_micros);
10.   }
12.   // Flush and publish stacks
13.   stacks->flush(&_allocator, &_stripes);
15.   // Free remaining stacks
16.   stacks->free(&_allocator);
17. }

复制代码

这里的 stripe 就是标记条带，stacks 是一个线程本地栈。
往下看 work_with_timeout 方法

1. void ZMark::work_with_timeout(ZMarkCache* cache, ZMarkStripe* stripe, ZMarkThreadLocalStacks* stacks, uint64_t timeout_in_micros) {
2.   ZStatTimer timer(ZSubPhaseMarkTryComplete);
3.   ZMarkTimeout timeout(timeout_in_micros);
5.   for (;;) {
6.     if (!drain(stripe, stacks, cache, &timeout)) {
7.       // Timed out
8.       break;
9.     }
11.     if (try_steal(stripe, stacks)) {
12.       // Stole work
13.       continue;
14.     }
16.     // Terminate
17.     break;
18.   }
19. }

复制代码

可以看到这里是一个循环，会一直从标记条带里取数据，直到取完了或时间到了。 这里就是 ZGC 三色标记的主循环了。 接下来看 drain 函数，drain 就是使排空的意思，这里就是从栈中取出指针进行标记，直到栈为空。

1. template <typename T>
2. bool ZMark::drain(ZMarkStripe* stripe, ZMarkThreadLocalStacks* stacks, ZMarkCache* cache, T* timeout) {
3.   ZMarkStackEntry entry;
5.   // Drain stripe stacks
6.   while (stacks->pop(&_allocator, &_stripes, stripe, entry)) {
7.     //标记和跟随
8.     mark_and_follow(cache, entry);
10.     // Check timeout
11.     if (timeout->has_expired()) {
12.       // Timeout
13.       return false;
14.     }
15.   }
17.   // Success
18.   return !timeout->has_expired();
19. }

复制代码

可以看到这里一直在从栈里取数据，然后标记和递归标记，直到栈排空。
既然有从栈里取数据的地方，那肯定有往栈里放数据的地方，我们先把这个点记下来，叫“记录点1”。
接着往下看 mark_and_follow 函数

1. void ZMark::mark_and_follow(ZMarkCache* cache, ZMarkStackEntry entry) {
2.   // Decode flags
3.   const bool finalizable = entry.finalizable();
4.   const bool partial_array = entry.partial_array();
6.   if (partial_array) {
7.     follow_partial_array(entry, finalizable);
8.     return;
9.   }
11.   // Decode object address and additional flags
12.   const uintptr_t addr = entry.object_address();
13.   const bool mark = entry.mark();
14.   bool inc_live = entry.inc_live();
15.   const bool follow = entry.follow();
17.   ZPage* const page = _page_table->get(addr);
18.   assert(page->is_relocatable(), "Invalid page state");
20.   // Mark
21.   //标记对象
22.   if (mark && !page->mark_object(addr, finalizable, inc_live)) {
23.     // Already marked
24.     return;
25.   }
27.   // Increment live
28.   if (inc_live) {
29.     // Update live objects/bytes for page. We use the aligned object
30.     // size since that is the actual number of bytes used on the page
31.     // and alignment paddings can never be reclaimed.
32.     const size_t size = ZUtils::object_size(addr);
33.     const size_t aligned_size = align_up(size, page->object_alignment());
34.     cache->inc_live(page, aligned_size);
35.   }
37.   // Follow
38.   if (follow) {
39.     if (is_array(addr)) {
40.       //递归处理数组
41.       follow_array_object(objArrayOop(ZOop::from_address(addr)), finalizable);
42.     } else {
43.       //递归处理对象
44.       follow_object(ZOop::from_address(addr), finalizable);
45.     }
46.   }
47. }

复制代码

这里有两个函数要看，我们先看 page->mark_object，再看 follow_object，至于follow_array_object，和 follow_object 类似，就不在详细介绍了。
page->mark_object 源码如下

1. inline bool ZPage::mark_object(uintptr_t addr, bool finalizable, bool& inc_live) {
2.   assert(ZAddress::is_marked(addr), "Invalid address");
3.   assert(is_relocatable(), "Invalid page state");
4.   assert(is_in(addr), "Invalid address");
6.   // Set mark bit
7.   const size_t index = ((ZAddress::offset(addr) - start()) >> object_alignment_shift()) * 2;
8.   return _livemap.set(index, finalizable, inc_live);
9. }

复制代码

可以看到这里用了一个 map，来存储了所有对象地址的 finalizable 和 inc_live(新增存活)信息。
const size_t index = ((ZAddress:ffset(addr) - start()) >> object_alignment_shift()) * 2;
从这个代码看，livemap 的大小大概是整个堆的对象对齐大小分之一，然后再乘以2。 这个 map 存的信息非常重要，ZGC中判断一个地址是否被标记过，一个对象是否存活都是通过这个 map 里的信息来判断的。
再回到上一步，继续看 follow_object 函数

1. void ZMark::follow_object(oop obj, bool finalizable) {
2.   if (finalizable) {
3.     ZMarkBarrierOopClosure<true /* finalizable */> cl;
4.     obj->oop_iterate(&cl);
5.   } else {
6.     ZMarkBarrierOopClosure<false /* finalizable */> cl;
7.     obj->oop_iterate(&cl);
8.   }
9. }

复制代码

这里根据 finalizable 分了两个分支，oop_iterate 看名字我们也能猜到这是做什么的，就是对对象里的指针进行迭代，但毕竟是猜测，具体还要看代码验证。
ZMarkBarrierOopClosure 这个看名字就是读屏障了，我们已经来到开头问题 3 的大门前了，只差临门一脚。 踹进读屏障的大门前，我们还得搬开挡在门口的一个大石头 oop_iterate 方法是怎么和 ZMarkBarrierOopClosure 联系上的。
2.2.2 对象迭代遍历

这一节将看 oop_iterate 内部逻辑，这个属于分支流程，暂不想了解的可以先跳过，直接看下一节 2.2.3 读屏障。
警告：抓紧扶手，下面车速开始加快了！
先把 cl 类型 ZMarkBarrierOopClosure 记录下来，我们记为 “记录点2”。
进入 oop_iterate 函数

1. template <typename OopClosureType>
2. void oopDesc::oop_iterate(OopClosureType* cl) {
3.   OopIteratorClosureDispatch::oop_oop_iterate(cl, this, klass());
4. }

复制代码

再往下

1. template <typename OopClosureType>
2. void OopIteratorClosureDispatch::oop_oop_iterate(OopClosureType* cl, oop obj, Klass* klass, MemRegion mr) {
3.   OopOopIterateBoundedDispatch<OopClosureType>::function(klass)(cl, obj, klass, mr);
4. }

复制代码

再往下

1. static FunctionType function(Klass* klass) {
2.     return _table._function[klass->id()];
3.   }

复制代码

function 方法在一个类中，_table 就是这个类的对象实例，_function 是个数组，我们看_function 怎么初始化值的。

1. public:
2.     FunctionType _function[KLASS_ID_COUNT];
4.     Table(){
5.       set_init_function<InstanceKlass>();
6.       set_init_function<InstanceRefKlass>();
7.       set_init_function<InstanceMirrorKlass>();
8.       set_init_function<InstanceClassLoaderKlass>();
9.       set_init_function<ObjArrayKlass>();
10.       set_init_function<TypeArrayKlass>();
11.     }

复制代码

table 构造方法与 _function 定义
这里有多个 Klass 对象，我们只看第一个。我们把 InstanceKlass 暂记为“记录点3”，接着往下看 set_init_function。

1. template <typename KlassType>
2.     void set_init_function() {
3.       _function[KlassType::ID] = &init<KlassType>;
4.     }

复制代码

往下看 init 函数

1. template <typename KlassType>
2.     static void init(OopClosureType* cl, oop obj, Klass* k, MemRegion mr) {
3.       OopOopIterateBoundedDispatch<OopClosureType>::_table.set_resolve_function_and_execute<KlassType>(cl, obj, k, mr);
4.     }

复制代码

继续

1. template <typename KlassType>
2.     void set_resolve_function_and_execute(OopClosureType* cl, oop obj, Klass* k, MemRegion mr) {
3.       set_resolve_function<KlassType>();
4.       _function[KlassType::ID](cl, obj, k, mr);
5.     }

复制代码

继续跟 set_resolve_function

1. template <typename KlassType>
2.     void set_resolve_function() {
3.       if (UseCompressedOops) {
4.         _function[KlassType::ID] = &oop_oop_iterate_bounded<KlassType, narrowOop>;
5.       } else {
6.         _function[KlassType::ID] = &oop_oop_iterate_bounded<KlassType, oop>;
7.       }
8.     }

复制代码

可以看到这里有个 UseCompressedOops，难道 ZGC 支持压缩指针了？感兴趣的同学可以深入研究下。
往下看 oop_oop_iterate_bounded

1. template <typename KlassType, typename T>
2.     static void oop_oop_iterate_bounded(OopClosureType* cl, oop obj, Klass* k, MemRegion mr) {
3.       ((KlassType*)k)->KlassType::template oop_oop_iterate_bounded<T>(obj, cl, mr);
4.     }

复制代码

这里可以看到调用了 KlassType 的 oop_oop_iterate_bounded 函数，KlassType 又是啥，这是一个泛型，其真实类型在这里其中之一就是记录点3的 InstanceKlass。
在 JVM 中一个普通的 Java 类是以一个 InstanceKlass 类型的 Klass 模型存在的。
以下就不属于 ZGC 的源码了，当然，仍然是 jvm 源码。
进入 InstanceKlass 的 oop_oop_iterate_bounded 函数

1. template <typename T, class OopClosureType>
2. ALWAYSINLINE void InstanceKlass::oop_oop_iterate_bounded(oop obj, OopClosureType* closure, MemRegion mr) {
3.   if (Devirtualizer::do_metadata(closure)) {
4.     if (mr.contains(obj)) {
5.       Devirtualizer::do_klass(closure, this);
6.     }
7.   }
9.   oop_oop_iterate_oop_maps_bounded<T>(obj, closure, mr);
10. }

复制代码

往下

1. template <typename T, class OopClosureType>
2. ALWAYSINLINE void InstanceKlass::oop_oop_iterate_oop_maps_bounded(oop obj, OopClosureType* closure, MemRegion mr) {
3.   //非静态成员变量块起始位置
4.   OopMapBlock* map           = start_of_nonstatic_oop_maps();
5.   //非静态成员变量块结束位置
6.   OopMapBlock* const end_map = map + nonstatic_oop_map_count();
7.   //对非静态成员变量块进行遍历
8.   for (;map < end_map; ++map) {
9.     oop_oop_iterate_oop_map_bounded<T>(map, obj, closure, mr);
10.   }
11. }

复制代码

可以看到这里对一个对象的非静态成员变量块进行了迭代遍历。 继续往下

1. template <typename T, class OopClosureType>
2. ALWAYSINLINE void InstanceKlass::oop_oop_iterate_oop_map_bounded(OopMapBlock* map, oop obj, OopClosureType* closure, MemRegion mr) {
3.   T* p   = (T*)obj->obj_field_addr<T>(map->offset());
4.   T* end = p + map->count();
6.   T* const l   = (T*)mr.start();
7.   T* const h   = (T*)mr.end();
8.   assert(mask_bits((intptr_t)l, sizeof(T)-1) == 0 &&
9.          mask_bits((intptr_t)h, sizeof(T)-1) == 0,
10.          "bounded region must be properly aligned");
12.   if (p < l) {
13.     p = l;
14.   }
15.   if (end > h) {
16.     end = h;
17.   }
19.   for (;p < end; ++p) {
20.     Devirtualizer::do_oop(closure, p);
21.   }
22. }

复制代码

这里继续对一个对象的非静态成员变量进行遍历。 继续看 Devirtualizer::do_oop

1. template <typename OopClosureType, typename T>
2. inline void Devirtualizer::do_oop(OopClosureType* closure, T* p) {
3.   call_do_oop<T>(&OopClosureType::do_oop, &OopClosure::do_oop, closure, p);
4. }

复制代码

继续

1. template <typename T, typename Receiver, typename Base, typename OopClosureType>
2. static typename EnableIf<IsSame<Receiver, Base>::value, void>::type
3. call_do_oop(void (Receiver::*)(T*), void (Base::*)(T*), OopClosureType* closure, T* p) {
4.   closure->do_oop(p);
5. }

复制代码

继续，但继续不动了，OopClosureType 是个模板类型，其真实类型是什么呢？一层层往上回溯，发现它就是记录点2的 ZMarkBarrierOopClosure 读屏障，这就又回到了 ZGC 主流程里了。
2.2.3 读屏障

进入 ZMarkBarrierOopClosure，由上一节可知，这个函数的入参 p 就是要标记对象的非静态成员变量的指针。

1. template <bool finalizable>
2. class ZMarkBarrierOopClosure : public ClaimMetadataVisitingOopIterateClosure {
3. public:
4.   ZMarkBarrierOopClosure() :
5.       ClaimMetadataVisitingOopIterateClosure(finalizable
6.                                                  ? ClassLoaderData::_claim_finalizable
7.                                                  : ClassLoaderData::_claim_strong,
8.                                              finalizable
9.                                                  ? NULL
10.                                                  : ZHeap::heap()->reference_discoverer()) {}
12.   virtual void do_oop(oop* p) {
13.     ZBarrier::mark_barrier_on_oop_field(p, finalizable);
14.   }
16.   virtual void do_oop(narrowOop* p) {
17.     ShouldNotReachHere();
18.   }
19. };

复制代码

继续看 mark_barrier_on_oop_field

1. //
2. // Mark barrier
3. //
4. inline void ZBarrier::mark_barrier_on_oop_field(volatile oop* p, bool finalizable) {
5.   const oop o = Atomic::load(p);
7.   if (finalizable) {
8.     barrier<is_marked_or_null_fast_path, mark_barrier_on_finalizable_oop_slow_path>(p, o);
9.   } else {
10.     const uintptr_t addr = ZOop::to_address(o);
11.     if (ZAddress::is_good(addr)) {
12.       // Mark through good oop
13.       mark_barrier_on_oop_slow_path(addr);
14.     } else {
15.       // Mark through bad oop
16.       barrier<is_good_or_null_fast_path, mark_barrier_on_oop_slow_path>(p, o);
17.     }
18.   }
19. }

复制代码

这里分了3个分支，finalizable先不看，根据指针是good还是bad有分了两个分支，这两个分支最终有都调用了 mark_barrier_on_oop_slow_path 慢路径处理方法。
这里直接看下面的第 2 个分支

1. template <ZBarrierFastPath fast_path, ZBarrierSlowPath slow_path>
2. inline oop ZBarrier::barrier(volatile oop* p, oop o) {
3.   const uintptr_t addr = ZOop::to_address(o);
5.   // Fast path
6.   if (fast_path(addr)) {
7.     return ZOop::from_address(addr);
8.   }
10.   // Slow path
11.   const uintptr_t good_addr = slow_path(addr);
13.   if (p != NULL) {
14.     //指针自愈
15.     self_heal<fast_path>(p, addr, good_addr);
16.   }
18.   return ZOop::from_address(good_addr);
19. }

复制代码

这是读屏障的核心逻辑代码，这里我们也看到了指针自愈。
从这段代码可以看到，首先执行快速路径检查，如果 fast_path(addr) 返回 true，则直接返回 addr 所对应的 oop 对象。 如果快速路径检查失败，则执行慢速路径检查，将 addr 传递给 slow_path 函数，并将返回值存储在 good_addr 变量中。 如果传入的指针 p 不为空，则调用 self_heal
这里的 slow_path 其实就是 mark_barrier_on_oop_slow_path 函数。
这里主要往下看两个函数，慢路径处理和指针自愈，慢路径处理流程比较长，我们先看指针自愈。

1. template <ZBarrierFastPath fast_path>
2. inline void ZBarrier::self_heal(volatile oop* p, uintptr_t addr, uintptr_t heal_addr) {
3.   if (heal_addr == 0) {
4.     // Never heal with null since it interacts badly with reference processing.
5.     // A mutator clearing an oop would be similar to calling Reference.clear(),
6.     // which would make the reference non-discoverable or silently dropped
7.     // by the reference processor.
8.     return;
9.   }
11.   assert(!fast_path(addr), "Invalid self heal");
12.   assert(fast_path(heal_addr), "Invalid self heal");
14.   for (;;) {
15.     // Heal
16.     const uintptr_t prev_addr = Atomic::cmpxchg((volatile uintptr_t*)p, addr, heal_addr);
17.     if (prev_addr == addr) {
18.       // Success
19.       return;
20.     }
22.     if (fast_path(prev_addr)) {
23.       // Must not self heal
24.       return;
25.     }
27.     // The oop location was healed by another barrier, but still needs upgrading.
28.     // Re-apply healing to make sure the oop is not left with weaker (remapped or
29.     // finalizable) metadata bits than what this barrier tried to apply.
30.     assert(ZAddress::offset(prev_addr) == ZAddress::offset(heal_addr), "Invalid offset");
31.     addr = prev_addr;
32.   }
33. }

复制代码

这个就比较简单了，类似 Java 的 cas 操作，把坏指针修改为好指针，然后执行快速路径。
好指针是上面执行慢路径返回的。
接下来看慢路径

1. //
2. // Mark barrier
3. //
4. uintptr_t ZBarrier::mark_barrier_on_oop_slow_path(uintptr_t addr) {
5.   assert(during_mark(), "Invalid phase");
6.   assert(ZThread::is_worker(), "Invalid thread");
8.   // Mark
9.   return mark<GCThread, Follow, Strong, Overflow>(addr);
10. }

复制代码

这里对进入读屏障的指针又进行了标记。
到这里，其实读屏障主要逻辑已经结束了，下面是读屏障触发的标记逻辑。
2.2.4 读屏障触发的标记逻辑

继续

1. template <bool gc_thread, bool follow, bool finalizable, bool publish>
2. uintptr_t ZBarrier::mark(uintptr_t addr) {
3.   uintptr_t good_addr;
5.   if (ZAddress::is_marked(addr)) {
6.     // Already marked, but try to mark though anyway
7.     good_addr = ZAddress::good(addr);
8.   } else if (ZAddress::is_remapped(addr)) {
9.     // Already remapped, but also needs to be marked
10.     good_addr = ZAddress::good(addr);
11.   } else {
12.     // Needs to be both remapped and marked
13.     good_addr = remap(addr);
14.   }
16.   // Mark
17.   if (should_mark_through<finalizable>(addr)) {
18.     ZHeap::heap()->mark_object<gc_thread, follow, finalizable, publish>(good_addr);
19.   }
21.   if (finalizable) {
22.     // Make the oop finalizable marked/good, instead of normal marked/good.
23.     // This is needed because an object might first becomes finalizable
24.     // marked by the GC, and then loaded by a mutator thread. In this case,
25.     // the mutator thread must be able to tell that the object needs to be
26.     // strongly marked. The finalizable bit in the oop exists to make sure
27.     // that a load of a finalizable marked oop will fall into the barrier
28.     // slow path so that we can mark the object as strongly reachable.
29.     return ZAddress::finalizable_good(good_addr);
30.   }
32.   return good_addr;
33. }

复制代码

这里要继续跟的函数有三个 ZAddress::good 、remap、ZHeap::heap()->mark_object。
ZHeap::heap()->mark_object 就是在堆中对对象进行标记。
先看下 ZAddress::good 的逻辑

1. inline uintptr_t ZAddress::offset(uintptr_t value) {
2.   return value & ZAddressOffsetMask;
3. }
5. inline uintptr_t ZAddress::good(uintptr_t value) {
6.   return offset(value) | ZAddressGoodMask;
7. }

复制代码

可以看到只是改变了下指针标记位，比较简单，也符合我们没读代码前对 ZGC 流程的认识。
2.2.5 重映射

继续看 remap 重映射方法，这里我们就找到了开头问题5【ZGC并发标记中的并发重映射过程】

1. uintptr_t ZBarrier::remap(uintptr_t addr) {
2.   assert(!ZAddress::is_good(addr), "Should not be good");
3.   assert(!ZAddress::is_weak_good(addr), "Should not be weak good");
4.   return ZHeap::heap()->remap_object(addr);
5. }

复制代码

继续

1. inline uintptr_t ZHeap::relocate_object(uintptr_t addr) {
2.   assert(ZGlobalPhase == ZPhaseRelocate, "Relocate not allowed");
4.   ZForwarding* const forwarding = _forwarding_table.get(addr);
5.   if (forwarding == NULL) {
6.     // Not forwarding
7.     return ZAddress::good(addr);
8.   }
10.   // Relocate object
11.   return _relocate.relocate_object(forwarding, ZAddress::good(addr));
12. }

复制代码

可以看到这里先查转发表，转发表中不存在直接返回好指针，存在则执行重分配操作，再往下就是重分配的逻辑了，本文中就不详解了，在以后重分配文章中的详细介绍。
2.2.6 回到读屏障标记流程

然后，返回 2.2.4 开头，继续看 ZHeap::heap()->mark_object

1. template <bool gc_thread, bool follow, bool finalizable, bool publish>
2. inline void ZHeap::mark_object(uintptr_t addr) {
3.   assert(ZGlobalPhase == ZPhaseMark, "Mark not allowed");
4.   _mark.mark_object<gc_thread, follow, finalizable, publish>(addr);
5. }

复制代码

继续

1. template <bool gc_thread, bool follow, bool finalizable, bool publish>
2. inline void ZMark::mark_object(uintptr_t addr) {
3.   assert(ZAddress::is_marked(addr), "Should be marked");
5.   ZPage* const page = _page_table->get(addr);
6.   if (page->is_allocating()) {
7.     // Already implicitly marked
8.     return;
9.   }
11.   const bool mark_before_push = gc_thread;
12.   bool inc_live = false;
14.   if (mark_before_push) {
15.     // Try mark object
16.     if (!page->mark_object(addr, finalizable, inc_live)) {
17.       // Already marked
18.       return;
19.     }
20.   } else {
21.     // Don't push if already marked
22.     if (page->is_object_marked<finalizable>(addr)) {
23.       // Already marked
24.       return;
25.     }
26.   }
28.   // Push
29.   ZMarkThreadLocalStacks* const stacks = ZThreadLocalData::stacks(Thread::current());
30.   ZMarkStripe* const stripe = _stripes.stripe_for_addr(addr);
31.   ZMarkStackEntry entry(addr, !mark_before_push, inc_live, follow, finalizable);
32.   stacks->push(&_allocator, &_stripes, stripe, entry, publish);
33. }

复制代码

这里有两个重要逻辑，一是已经标记的不再进行 push，二是未标记过的 push 到栈里。
还记得前面的“记录点1”吗，push 指针 到栈里的地方就是这儿了，被 push 的指针将会在下次标记循环中被取出来。
到此，ZGC 三色标记的主流程就头尾相接了，完结撒花。
3、问题回顾

3.1 开头的问题

• ZGC是如何在指针上标记的
  
• ZGC三色标记的过程
  
• ZGC只用了读屏障是如何防止漏标的
  
• ZGC标记过程中的指针自愈过程
  
• ZGC并发标记中的并发重映射过程
  

上面5个问题，1、2、4、5上面源码分析过程中都已经有了，问题3是要从整个流程上看。
3.2 ZGC只用了读屏障是如何防止漏标的

3.2.1 什么情况下会漏标

当以下两个情况同时发生时：

• 新增了一个从黑色对象到白色对象的新引用
  
• 删除了全部从灰色对象到该白色对象的引用
  

3.2.2 如何避免？

破坏条件1，这就是增量更新(Incremental Update)解决方案。
破坏条件2，这就是原始快照(Snapshot At The Beginning， SAT B )解决方案。
ZGC 采用的是增量更新解决方案。但是，增量更新不是新增吗，应该是写屏障啊，读屏障怎么做到呢？
其实新增一个引用时，之前肯定要从某处读到这个引用，那么这个读的操作便触发了读屏障。前面源码中，我们知道 ZGC 读屏障里有一个标记的过程，而且还会自动返回好指针，也就是说经过读屏障返回的指针中不存在白色对象，这就从根本上避免了条件1。
4、扩展思考

ZGC 标记是在指针上，而不是在对象上，当回收某个 region 时，对于此 region 里的某个对象，无法获得其他对象指向此对象的指针，那如何得知这对象是否存活呢？
这个问题需要我们将标记阶段和重分配阶段的代码连起来看才能得到答案了。
5、结束

对于ZGC并发标记的过程的源码分析就到这里了，如果觉得对您有启发或有帮助就多多点赞支持呀~

作者：京东物流 刘家存
来源：京东云开发者社区 自猿其说Tech 转载请注明来源

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！