当前位置: 首页 > news >正文

设计一个Rust线程安全栈结构 Stack<T>

在Rust中,设计一个线程安全的栈结构Stack<T>,类似于Channel<T>,但使用栈的FILO(First-In-Last-Out)原则来在线程间传送数据,可以通过使用标准库中的同步原语如MutexCondvar来实现。下面是一个简单的实现示例:

use std::collections::VecDeque;
use std::sync::{Mutex, Condvar};
use std::thread;
use std::time::Duration;pub struct Stack<T> {data: Mutex<VecDeque<T>>,not_empty: Condvar,
}impl<T> Stack<T> {pub fn new() -> Stack<T> {Stack {data: Mutex::new(VecDeque::new()),not_empty: Condvar::new(),}}pub fn push(&self, item: T) {let mut data = self.data.lock().unwrap();data.push_front(item);self.not_empty.notify_one();}pub fn pop(&self) -> Option<T> {let mut data = self.data.lock().unwrap();while data.is_empty() {data = self.not_empty.wait(data).unwrap().0;}data.pop_back()}
}// 示例用法
fn main() {let stack = Stack::new();let producer = thread::spawn(move || {for i in 1..=5 {stack.push(i);println!("Produced {}", i);thread::sleep(Duration::from_millis(500));}});let consumer = thread::spawn(move || {while let Some(item) = stack.pop() {println!("Consumed {}", item);}});producer.join().unwrap();consumer.join().unwrap();
}

在这个示例中,Stack<T>结构包含了一个受互斥锁保护的VecDeque<T>,它用作底层的数据存储。VecDeque是一个双端队列,但在这里我们只使用其作为栈的功能,通过push_frontpop_back方法来模拟栈的行为。not_empty是一个条件变量,用于在栈为空时阻塞消费者线程,直到有数据可用。

push方法中,我们将数据项推入栈中,并通过notify_one方法唤醒一个等待的消费者线程(如果有的话)。在pop方法中,我们检查栈是否为空,并在为空时使用wait方法阻塞当前线程,直到有数据被推入栈中。当栈不为空时,我们从栈中弹出一个数据项并返回它。

在示例的main函数中,我们创建了一个Stack<i32>实例,并启动了一个生产者线程和一个消费者线程。生产者线程将数字1到5推入栈中,每次推送后休眠500毫秒。消费者线程则不断地从栈中弹出数据项,并打印它们,直到栈为空为止。

http://www.lryc.cn/news/330163.html

相关文章:

  • Docker Desktop 在 Windows 上的安装和使用
  • 2024年最受欢迎的 19 个 VS Code 主题排行榜
  • 突破编程_C++_网络编程(OSI 七层模型(物理层与数据链路层))
  • Spring boot如何使用redis缓存
  • 红蓝色WordPress外贸建站模板
  • python爬虫----了解爬虫(十一天)
  • 碳素光线疗法与宠物健康
  • 展锐平台camera添加底层水印
  • OSX-02-Mac OS应用开发系列课程大纲和章节内容设计
  • 热门IT【视频教程】-华为/思科/红帽/oracle
  • HCTNet:一种用于乳腺超声图像分割的混合CNN-transformer
  • 766. 托普利茨矩阵
  • 基于STM32的汽车防窒息系统
  • GoogleNet神经网络介绍
  • AI水下颜色校正解决方案,助力企业打造水下视觉盛宴
  • LINUX笔记温习
  • 钉钉服务端API报错 43008 参数需要multipart类型
  • HarmonyOS NEXT应用开发案例——阻塞事件冒泡
  • 【C语言】联合和枚举
  • 苹果手机黑屏打不开怎么办?5种方法让你轻松应对
  • 鸿蒙:滑动条组件Slider
  • 【智能家居项目】RT-Thread版本——DHT11获取温湿度 | MQTT上传到服务器 | 服务器控制外设
  • Docker 轻量级可视化工具 Portainer
  • 推特Twitter有直播功能吗?如何用Twitter直播?
  • 蓝桥杯算法基础(32):素数,埃式筛法,快速幂,斐波那契与矩阵幂运算
  • VSCode - 离线安装扩展python插件教程
  • 2024年中级职称现在报名,时间还太早了吗?什么时候合适?
  • 《责任链模式(极简c++)》
  • 【学习】JMeter和Postman两种测试工具的主要区别有哪些
  • 【压缩字符串算法解析与实现】