生产者消费者
例如下场景:某个模块负责产生数据,这些数据由另一个模块来负责处理(此处的模块是广义的,可以是类、函数、线程、进程等)。产生数据的模块,就形象地称为生产者;而处理数据的模块,就称为消费者。 我们举一个寄信的例子,假设你要寄一封平信,大致过程如下:
- 你把信写好——相当于生产者制造数据
- 你把信放入邮筒——相当于生产者把数据放入缓冲区
- 邮递员把信从邮筒取出——相当于消费者把数据取出缓冲区
- 邮递员把信拿去邮局做相应的处理——相当于消费者处理数据
生产者消费者模式可以用来处理并发问题的。 从寄信的例子来看。如果没有邮筒,你得拿着信傻站在路口等邮递员过来收(相当于生产者阻塞);又或者邮递员得挨家挨户问,谁要寄信(相当于消费者轮询)。
代码语言:javascript复制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 "rn");
//消费
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();
}
}
}