C应用程序设计教程(第2版)第7章-进程和多线程.ppt

7.4.1 生产者线程和消费者线程不同步可能发生错误 【例7.13】下边的例子模拟生产者线程和消费者线程不同步可能发生错误。有一个公共变量，要求生产者线程顺序放1到4到这个公共变量中，每放一个变量，消费者线程取出这个数求和，最后把和显示出来，显然和应为10。如不采取同步措施，和的结果不正确。 （1）新建项目。在Window1.xaml.cs头部增加语句：using System.Threading; （2）在Window1类定义2个线程类变量：Thread thread1,thread2; （3）在Window1类定义2个整形变量：int sum=0,x=-1; （4）在窗体中放置一个TextBlock和按钮控件，按钮的事件处理函数如下： private void button1_Click(object sender, EventArgs e) { textBlock1.Text = sum.ToString(); } （5）在Window1类构造函数最后增加如下语句： thread1= new Thread(new ThreadStart(Fun1)); thread2= new Thread(new ThreadStart(Fun2)); thread1.Start(); thread2.Start(); （6）为Form1类定义Fun1()和Fun2()方法如下： public void Fun1() {for(int k=1;k5;k++) {x=k; Thread.Sleep(200);} } public void Fun2() {for(int k=0;k4;k++) {sum+=x; Thread.Sleep(100);} } （7）编译运行，单击按钮，标签控件应显示10，实际运行多次，显示的数不为10。 7.4.2 生产者线程和消费者线程同步的实现 【例7.14】修改上例，为Window1类定义1个布尔变量：bool mark=false。其值为false，表示数据还未放到公共数据区(即x)中，生产者线程可以放数据到公共数据区中，由于没有数据，消费线程不能取数据，必须等待。mark=true，表示数据已放到公共数据区(即x)中，消费线程还未取数据，生产者线程不能再放数据到公共数据区中，必须等待。由于有了数据，消费线程可以取数据。修改Fun1()如下： public void Fun1() { for(int k=1;k5;k++) { Monitor.Enter(this); if(mark) Monitor.Wait(this); mark=!mark; x=k; Monitor.Pulse(this); Monitor.Exit(this); } } } 修改Fun2()如下： public void Fun2() { for(int k=0;k4;k++) { Monitor.Enter(this); if(!mark) Monitor.Wait(this); mark=!mark; sum+=x; Monitor.Pulse(this); Monitor.Exit(this); } } 编译，运行，单击按钮，标签控件应显示10。 （3）定义一个修改TextBlock属性Text的方法： public void ShowSum(string s) { textBlock1.Text = s; } （4）在Window1类中定义一个新委托类型： public delegate int sumDelegate(int x,int y); public delegate void ShowDelegate(string s); （5）为标题为求和的按钮(button1)增加单击事件处理函数如下： private void button1_Click(object sender, RoutedEventArgs e) { sumDelegate b = new sumDelegate(SumFun); b.BeginInvoke(10, 10, new AsyncCallback(MyCallBackF),10+10的和是:); } （6）在Window1类定义一个回调方法如下： void MyCallBackF(IAsyncResult itfAR) { AsyncResult ar = (AsyncResult)itfAR; string s = (string)itfAR.As