c#线程基础之线程控制

用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();

        }

    }

}