crossbeam-epoch中基于epoch的無鎖垃圾收集原理是什么

這篇文章給大家介紹crossbeam-epoch中基于epoch的無鎖垃圾收集原理是什么，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

crossbeam提供了一個(gè)基于epoch的“垃圾收集”(epoch based reclamation)庫。首先來簡單的說一下這一垃圾回收的原理。

基于epoch的“垃圾回收”

1. 一個(gè)全局的epoch計(jì)數(shù)器
2. 每個(gè)線程有一個(gè)本地的epoch計(jì)數(shù)器
3. 一個(gè)全局列表記錄每個(gè)epoch產(chǎn)生的垃圾
4. 標(biāo)示線程是否活躍的標(biāo)示符

crossbeam-epoch的API

Guard

    
  
  
  
use crossbeam_epoch as epoch;
let guard = &epoch::pin();
  
  
  
 
  
  

    
  
  
  pub unsafe fn defer_destroy<T>(&self, ptr: Shared<T>)

Shared

Owned

Atomic

    
  
  
  pub fn load(&self, ord: Ordering, &'g Guard) -> Shared<'g, 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>,

實(shí)現(xiàn)并發(fā)棧

    
  
  
  
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>, // 告訴編譯器該變量不需要自動(dòng)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(); // 標(biāo)記當(dāng)前線程為活躍
        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(); // 標(biāo)記當(dāng)前線程為活躍        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))); // 返回節(jié)點(diǎn)中的數(shù)據(jù)                        }                    }                }                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() {}    }}
  
 
  
 
  
  

關(guān)于crossbeam-epoch中基于epoch的無鎖垃圾收集原理是什么就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。