曾今的代码系列——生产者消费者模式
曾今的代码系列——生产者消费者模式
木宛城主 发表于3年前
曾今的代码系列——生产者消费者模式
  • 发表于 3年前
  • 阅读 7
  • 收藏 0
  • 点赞 0
  • 评论 0

【腾讯云】新注册用户域名抢购1元起>>>   

生产者消费者

例如下场景:某个模块负责产生数据,这些数据由另一个模块来负责处理(此处的模块是广义的,可以是类、函数、线程、进程等)。产生数据的模块,就形象地称为生产者;而处理数据的模块,就称为消费者

我们举一个寄信的例子,假设你要寄一封平信,大致过程如下:

  • 你把信写好——相当于生产者制造数据
  • 你把信放入邮筒——相当于生产者把数据放入缓冲区
  • 邮递员把信从邮筒取出——相当于消费者把数据取出缓冲区
  • 邮递员把信拿去邮局做相应的处理——相当于消费者处理数据

生产者消费者模式可以用来处理并发问题的。
从寄信的例子来看。如果没有邮筒,你得拿着信傻站在路口等邮递员过来收(相当于生产者阻塞);又或者邮递员得挨家挨户问,谁要寄信(相当于消费者轮询)。

namespace 生产者消费者 { delegate void MyDelegate(string s); public partial class Form1 : Form { public Form1() { InitializeComponent(); //消费者线程
            System.Threading.Thread thread = new System.Threading.Thread(() => { while (true) { foreach (string data in listData.ToArray()) { MyDelegate doXF = s => txtLog.AppendText(s + "\r\n"); //消费
 txtLog.Invoke(doXF, data); //消费了产品之后就把它移除
 listData.Remove(data); } //降低CPU压力
                    System.Threading.Thread.Sleep(5000); } }); thread.IsBackground = true; thread.Start(); } List<string> listData = new List<string>(); private void btnProduct_Click(object sender, EventArgs e) { //生产
 listData.Add(txtData.Text); txtData.Clear(); txtData.Focus(); } } }

 

  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 2
博文 222
码字总数 199010
×
木宛城主
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: