面试题：Rust条件变量与其他同步原语的对比及优化

1. 性能、适用场景区别

条件变量：
- 性能：适用于线程需要等待某个条件满足后再继续执行的场景。它不会像自旋锁那样持续消耗CPU资源，而是让线程进入睡眠状态，当条件满足时被唤醒。但唤醒线程以及上下文切换存在一定开销。
- 适用场景：常用于生产者 - 消费者模型，比如生产者线程生产数据放入队列，消费者线程在队列空时等待，队列有数据时被唤醒消费。
信号量：
- 性能：通过计数器来控制对共享资源的访问。获取信号量（计数器减1）和释放信号量（计数器加1）操作通常效率较高，但如果信号量的竞争非常激烈，可能会带来一定的性能开销。
- 适用场景：用于控制对有限数量共享资源的访问。例如，数据库连接池，用信号量来限制同时获取连接的线程数量。
自旋锁：
- 性能：自旋锁在获取锁时，如果锁不可用，线程会在原地不断尝试获取锁，持续消耗CPU资源。适用于锁的持有时间极短的场景，因为避免了线程上下文切换的开销。但如果持有时间较长，会浪费大量CPU资源。
- 适用场景：多核CPU环境下，临界区代码执行时间非常短的情况，例如单核CPU中自旋锁没有意义，因为同一时间只有一个线程能运行。

2. 高并发性能优化思路

综合使用思路：
- 结合条件变量和互斥锁：使用互斥锁来保护共享数据，条件变量用于线程间的通知。当某个线程需要等待某个条件时，它先获取互斥锁，然后在条件变量上等待，等待时会自动释放互斥锁，让其他线程可以访问共享数据。当条件满足时，通过条件变量唤醒等待的线程，被唤醒的线程重新获取互斥锁后继续执行。
- 引入信号量控制资源访问：在需要限制对某些共享资源访问数量的场景下，结合信号量。例如，在生产者 - 消费者模型中，如果共享队列有最大容量限制，可以用信号量来控制生产者向队列中添加元素的数量。
- 谨慎使用自旋锁：在临界区代码执行非常快且CPU资源充足的情况下，对于短时间需要频繁获取释放的锁，可以考虑使用自旋锁来减少线程上下文切换开销。但要避免自旋时间过长导致CPU资源浪费。

3. 代码示例

use std::sync::{Arc, Condvar, Mutex};
use std::thread;

fn main() {
    let pair = Arc::new((Mutex::new(false), Condvar::new()));
    let pair2 = pair.clone();

    // 生产者线程
    thread::spawn(move || {
        let (lock, cvar) = &*pair;
        let mut data = lock.lock().unwrap();
        *data = true;
        println!("Producer set data to true");
        cvar.notify_one();
    });

    // 消费者线程
    thread::spawn(move || {
        let (lock, cvar) = &*pair2;
        let mut data = lock.lock().unwrap();
        while!*data {
            data = cvar.wait(data).unwrap();
        }
        println!("Consumer saw data is true");
    });

    thread::sleep(std::time::Duration::from_millis(100));
}

上述代码展示了条件变量与互斥锁的配合使用，生产者线程设置数据并通知消费者线程，消费者线程等待数据满足条件后继续执行。在实际高并发场景中，可根据具体需求结合信号量、自旋锁等进一步优化线程同步机制。例如，如果共享数据访问存在资源限制，可引入信号量：

use std::sync::{Arc, Condvar, Mutex, Semaphore};
use std::thread;

fn main() {
    let semaphore = Arc::new(Semaphore::new(3));
    let pair = Arc::new((Mutex::new(false), Condvar::new()));
    let pair2 = pair.clone();

    // 生产者线程
    thread::spawn(move || {
        let permit = semaphore.acquire().unwrap();
        let (lock, cvar) = &*pair;
        let mut data = lock.lock().unwrap();
        *data = true;
        println!("Producer set data to true");
        cvar.notify_one();
        drop(permit);
    });

    // 消费者线程
    thread::spawn(move || {
        let (lock, cvar) = &*pair2;
        let mut data = lock.lock().unwrap();
        while!*data {
            data = cvar.wait(data).unwrap();
        }
        println!("Consumer saw data is true");
    });

    thread::sleep(std::time::Duration::from_millis(100));
}

这里引入信号量来限制生产者对共享资源的访问数量，在获取信号量许可后才能操作共享数据，从而优化线程同步机制。

星途面试题库

面试题：Rust条件变量与其他同步原语的对比及优化

知识考点

面试题答案

1. 性能、适用场景区别

2. 高并发性能优化思路

3. 代码示例