Rust语言

关注公众号 jb51net

关闭
首页 > 软件编程 > Rust语言 > Rust Send 和 Sync trait

深入理解Rust中的 Send 和 Sync trait

作者:alwaysrun

Rust中的标记 trait(Marker Trait)Send和Sync是并发安全的核心基石,这篇文章给大家介绍Rust中的Send和Sync trait,感兴趣的朋友跟随小编一起看看吧

Rust中的标记 trait(Marker Trait)SendSync 是并发安全的核心基石。用于标记类型的并发安全属性,让编译器在编译时检查线程间数据传递的合法性,从根源上避免数据竞争(Data Race)。

Send

一个类型 TSend,表示把 T 的一个 值 从一个线程移动到另一个线程,不会引发数据竞争或内存安全问题。

绝大多数类型自动实现 Send,以下一些例外(!Send):

use std::thread;
fn main() {
    let v = vec![1, 2, 3];
    // Vec<i32> 是 Send,通过move把所有权移到线程中
    let handle = thread::spawn(move || {
        println!("{:?}", v);
    });
    handle.join().unwrap();
}

sync

一个类型 TSync,表示可以安全地被多个线程共享(即 &TSend)。即,如果一个类型的引用 &T 能安全跨线程传递,那么这个类型就是 Sync(多个线程持有 &T 不会导致数据竞争)。

任何允许通过 共享引用 &T 获得可变访问 且没有同步保护的类型,都不是 Sync

use std::sync::{Arc, Mutex};
use std::thread;
fn main() {
    let data = Arc::new(Mutex::new(5)); // Arc<Mutex<i32>>
    let data_clone = data.clone();
    thread::spawn(move || {
        let mut guard = data_clone.lock().unwrap(); // 加锁,独占访问
        *guard += 1;
    }).join().unwrap();
    println!("{}", data.lock().unwrap()); // 输出 6
}

auto trait

SendSync 都是 auto trait,编译器会根据类型的组成部分自动推导实现。

性质含义常见例子
Send + Sync可以在线程间移动,也可以多线程共享引用i32, Mutex<T>
Send + !Sync可以在线程间移动,但不能多线程共享引用一些 *mut T封装,Sender<T>
!Send + Sync不能跨线程移动;不移动,只读共享是安全的(较少见)少数特殊 FFI 对象
!Send + !Sync既不能跨线程移动,也不能多线程共享引用Rc<RefCell<T>>

只有在特殊情况下(写 底层库 / FFI 封装 / 自己的锁和原子数据结构 时)才会需要手动实现SendSync

use std::sync::Mutex;
// 自定义类型:用 Mutex 保护裸指针(裸指针本身 !Send/!Sync)
struct SafePtr<T>(Mutex<*mut T>);
impl<T> SafePtr<T> {
    fn new(value: T) -> Self {
        let ptr = Box::into_raw(Box::new(value)); // 裸指针指向堆内存
        SafePtr(Mutex::new(ptr))
    }
    // 安全访问:通过 Mutex 加锁,保证独占访问
    fn get(&self) -> Option<&T> {
        let guard = self.0.lock().ok()?;
        unsafe { (*guard).as_ref() } // 裸指针解引用需 unsafe,但锁保证安全
    }
}
// 手动实现 Send/Sync:因为内部用 Mutex 保护,访问裸指针是线程安全的
unsafe impl<T> Send for SafePtr<T> {}
unsafe impl<T> Sync for SafePtr<T> {}
// 测试:跨线程共享 SafePtr
fn main() {
    let ptr = SafePtr::new(5);
    let ptr_clone = Arc::new(ptr);
    let ptr_clone2 = ptr_clone.clone();
    thread::spawn(move || {
        println!("线程内访问:{}", ptr_clone2.get().unwrap()); // 安全
    }).join().unwrap();
}

到此这篇关于深入理解Rust中的 Send 和 Sync trait的文章就介绍到这了,更多相关Rust Send 和 Sync trait内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文