在開發中經常會遇到線程的例子,如果某個後台操作比較費時間,我們就可以啟動一個線程去執行那個費時的操作,同時程序繼續執行。在某些情況下可能會出現多個線程的同步協同的問題,下面的例子就展示了在兩個線程之間如何協同工作。
這個程序的思路是共同做一件事情(從一個ArrayList中刪除元素),如果執行完成了,兩個線程都停止執行。
代碼如下:
using System;
using System.Collections;
using System.Collections.Generic;
using System.Threading;
/// <summary>
/// 在開發中經常會遇到線程的例子,如果某個後台操作比較費時間,我們就可以啟動一個線程去執行那個費時的操作,同時程序繼續執行。在某些情況下可能會出現多個線程的同步協同的問題,下面的例子就展示了在兩個線程之間如何協同工作。
///
///這個程序的思路是共同做一件事情(從一個ArrayList中刪除元素),如果執行完成了,兩個線程都停止執行。
///作者:周公
/// 時間:2008-5-17
/// 原發地址:http://blog.csdn.net/zhoufoxcn
/// </summary>
public class ThreadDemo
{
private Thread threadOne;
private Thread threadTwo;
private ArrayList stringList;
private event EventHandler OnNumberClear;//數據刪除完成引發的事件
public static void Main()
{
ThreadDemo demo = new ThreadDemo(1000);
demo.Action();
}
public ThreadDemo(int number)
{
Random random = new Random(1000000);
stringList = new ArrayList(number);
for (int i = 0; i < number; i++)
{
stringList.Add(random.Next().ToString());
}
threadOne = new Thread(new ThreadStart(Run));//兩個線程共同做一件事情
threadTwo = new Thread(new ThreadStart(Run));//兩個線程共同做一件事情
threadOne.Name = "線程1";
threadTwo.Name = "線程2";
OnNumberClear += new EventHandler(ThreadDemo_OnNumberClear);
}
/// <summary>
/// 開始工作
/// </summary>
public void Action()
{
threadOne.Start();
threadTwo.Start();
}
/// <summary>
/// 共同做的工作
/// </summary>
private void Run()
{
string stringValue = null;
while (true)
{
Monitor.Enter(this);//鎖定,保持同步
stringValue = (string)stringList[0];
Console.WriteLine(Thread.CurrentThread.Name + "刪除了" + stringValue);
stringList.RemoveAt(0);//刪除ArrayList中的元素
if (stringList.Count == 0)
{
OnNumberClear(this, new EventArgs());//引發完成事件
}
Monitor.Exit(this);//取消鎖定
Thread.Sleep(5);
}
}
//執行完成之後,停止所有線程
void ThreadDemo_OnNumberClear(object sender, EventArgs e)
{
Console.WriteLine("執行完了,停止了所有線程的執行。");
threadTwo.Abort();
threadOne.Abort();
}
}
說明:要實現線程同步不止這一種方式。在這裡采用了事件,在事件處理程序裡中止了線程
OnNumberClear += new EventHandler(ThreadDemo_OnNumberClear);
OnNumberClear是事件
EventHandler是委托
ThreadDemo_OnNumberClear是方法名
上面這句代碼的意思是當OnNumberClear事件激發後將由ThreadDemo_OnNumberClear方法進行處理。