这篇文章给大家介绍crossbeam-epoch中基于epoch的无锁垃圾收集原理是什么，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
crossbeam提供了一个基于epoch的“垃圾收集”(epoch based reclamation)库。首先来简单的说一下这一垃圾回收的原理。
计算
安全
数据库
网络和加速
企业服务
pin
可以产生
Guard
，这将当前线程标识为活跃
use crossbeam_epoch as epoch;let guard = &epoch::pin();AI代码助手复制代码
defer_destroy
则将数据放入垃圾列表，等待2个epoch之后就可以被清理了
pub unsafe fn defer_destroy<T>(&self, ptr: Shared<T>)defer_destroy
的函数签名中看到了
Shared<T>
，这是一个被Guard的生命周期
'g
所保护的指针类型，相当于
&'g T
。它保证了Guard存在期间数据的可访问。Box<T>
，是一个不会被其他线程接触到的量。Guard
的保护下从中读出
Shared<T>
pub fn load(&self, ord: Ordering, &'g Guard) -> Shared<'g, T>Owned<T>
或者
Shared<T>
（即
Pointer<T>
）存入
pub fn store<P>(&self, new: P, ord: Ordering)where P: Pointer<T>,
pub fn compare_and_set<O, P>( &self, current: Shared<T>, new: P, ord: O, &'g Guard) -> Result<Shared<'g, T>, CompareAndSetError<'g, T, P>>where O: CompareAndSetOrdering, P: Pointer<T>,
use std::mem::ManuallyDrop;use std::ptr;use std::sync::atomic::Ordering::{Acquire, Relaxed, Release};use crossbeam_epoch::{self as epoch, Atomic, Owned};#[derive(Debug)]pub struct TreiberStack<T> { head: Atomic<Node<T>>,}#[derive(Debug)]struct Node<T> { data: ManuallyDrop<T>, // 告诉编译器该变量不需要自动Drop next: Atomic<Node<T>>,}impl<T> TreiberStack<T> { pub fn new() -> TreiberStack<T> { TreiberStack { head: Atomic::null(), } } pub fn push(&self, t: T) { let mut n = Owned::new(Node { data: ManuallyDrop::new(t), next: Atomic::null(), }); let guard = epoch::pin(); // 标记当前线程为活跃 loop { let head = self.head.load(Relaxed, &guard); n.next.store(head, Relaxed); match self.head.compare_and_set(head, n, Release, &guard) { // CAS Ok(_) => break, Err(e) => n = e.new, } } } pub fn pop(&self) -> Option<T> { let guard = epoch::pin(); // 标记当前线程为活跃 loop { let head = self.head.load(Acquire, &guard); match unsafe { head.as_ref() } { Some(h) => { let next = h.next.load(Relaxed, &guard); if self .head .compare_and_set(head, next, Relaxed, &guard) // CAS .is_ok() { unsafe { guard.defer_destroy(head); // 将垃圾加入列表 return Some(ManuallyDrop::into_inner(ptr::read(&(*h).data))); // 返回节点中的数据 } } } None => return None, } } } pub fn is_empty(&self) -> bool { let guard = epoch::pin(); self.head.load(Acquire, &guard).is_null() }}impl<T> Drop for TreiberStack<T> { fn drop(&mut self) { while self.pop().is_some() {} }}AI代码助手复制代码
关于crossbeam-epoch中基于epoch的无锁垃圾收集原理是什么就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/u/4581704/blog/4464834
