Rust有没有信号量机制，在缓存有数据的时候才允许等待的进程取数据？

Rust提供了信号量（Semaphore）机制，尽管它并没有直接提供类似于某些其他编程语言中的Semaphore类。然而，你可以使用std::sync::Mutex和std::sync::Condvar（条件变量）组合来实现信号量的功能。

信号量通常用于控制对共享资源的访问，通过维护一个计数器来限制同时访问资源的线程数。当资源可用时（即缓存中有数据时），等待的线程可以被唤醒并获取资源。

在Rust中，你可以使用Mutex来保护共享资源并提供互斥访问，同时使用Condvar来让等待的线程在条件满足时被唤醒。下面是一个简单的示例，展示了如何使用Mutex和Condvar来实现一个信号量，该信号量允许在缓存有数据时唤醒等待的线程：

use std::sync::{Mutex, Condvar, Arc};  
use std::thread;  
use std::time::Duration;  // 缓存结构  
struct Cache {  data: Mutex<Vec<i32>>,  // 互斥锁保护的数据  not_empty: Condvar,     // 条件变量，用于等待数据可用  not_full: Condvar,      // 条件变量，用于等待空间可用（如果需要的话）  
}  impl Cache {  fn new(capacity: usize) -> Cache {  Cache {  data: Mutex::new(Vec::with_capacity(capacity)),  not_empty: Condvar::new(),  not_full: Condvar::new(),  }  }  // 尝试从缓存中取出数据  fn try_pop(&self) -> Option<i32> {  let mut data = self.data.lock().unwrap();  if data.is_empty() {  None  } else {  Some(data.remove(0))  }  }  // 向缓存中添加数据  fn push(&self, value: i32) {  let mut data = self.data.lock().unwrap();  data.push(value);  self.not_empty.notify_one(); // 通知可能等待的消费者线程  }  // 从缓存中获取数据，如果没有数据则阻塞  fn pop(&self) -> i32 {  let mut data = self.data.lock().unwrap();  while data.is_empty() {  // 等待直到有数据可用或超时  self.not_empty.wait(data.as_mut()).unwrap();  }  data.remove(0)  }  
}  fn main() {  let cache = Arc::new(Cache::new(10)); // 假设缓存容量为10  // 生产者线程  let producer = thread::spawn(move || {  for i in 1..=5 {  thread::sleep(Duration::from_secs(1));  cache.push(i);  println!("Produced: {}", i);  }  });  // 消费者线程  let consumer = thread::spawn(move || {  for _ in 1..=5 {  let value = cache.pop();  println!("Consumed: {}", value);  }  });  // 等待生产者和消费者线程完成  producer.join().unwrap();  consumer.join().unwrap();  
}