c#线程基础之线程控制

csstome

用ManualResetEvent和AutoResetEvent可以很好的控制线程的运行和线程之间的通信。msdn的参考为： http://msdn.microsoft.com/zh-cn/library/system.threading.autoresetevent.aspx http://msdn.microsoft.com/zh-cn/library/system.threading.manualresetevent.aspx 下面我写个例子，这里模拟了一个线程更新数据，两个线程读取数据。更新的时候需要阻止读取的两个现成工作。而另外还有一个信号量来控制线程的退出。
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Text;using System.Windows.Forms;namespace WindowsApplication35{    public partial class Form1 : Form    {        public Form1()        {            InitializeComponent();        }        System.Threading.ManualResetEvent mEvent = new System.Threading.ManualResetEvent(true);        //判断线程安全退出的信号量        System.Threading.ManualResetEvent mEventStopAll = new System.Threading.ManualResetEvent(false);        //*******ManualResetEvent的用法。        private void button1_Click(object sender, EventArgs e)        {            //一个线程模拟写入            new System.Threading.Thread(invokeWrite).Start();            //两个线程模拟读取            new System.Threading.Thread(invokeRead).Start();            new System.Threading.Thread(invokeRead).Start();        }        private void invokeWrite()        {            for (int i = 0; i < 100; i++)            {                //判断线程安全退出                if (mEventStopAll.WaitOne(10, false) == true) break;                //设置信号量,假设更新数据需要2秒,每更新一次暂停2秒.                mEvent.Reset();                Console.WriteLine("正在更新...");                System.Threading.Thread.Sleep(2000);                mEvent.Set();                System.Threading.Thread.Sleep(2000);            }        }        private void invokeRead()        {            while (mEvent.WaitOne() == true)            {                //判断线程安全退出                if (mEventStopAll.WaitOne(10, false) == true) break;                //假设读取一体数据用10毫秒.他需要判断信号量开关.                Console.WriteLine("读取一条数据:");                System.Threading.Thread.Sleep(10);            }        }        private void Form1_FormClosing(object sender, FormClosingEventArgs e)        {            mEventStopAll.Set();        }    }}