封装 .NET 框架提供的 Thread代码,CSharp代码库,德仔网

代码语言
代码分类
【CSharp】封装 .NET 框架提供的 Thread
作者:Dezai.CN / 发布于2012/12/6/ 627
using System;
using System.Threading;
namespace CustomThreadPool
{
/// <summary>
/// 封装 .NET 框架提供的 Thread
/// </summary>
internal class MyThread
{
private Thread t; //线程
private WaitCallback w; //委托，这里直接用 .NET 框架自带的，也可以根据需要自己定义一个
private Object o; //传递给符合委托的回调方法的参数值，根据委托的定义而定
/// <summary>
/// 执行回调方法的线程
/// </summary>
public Thread T
{
get
{
return t;
}
}
public MyThread()
{
}
/// <summary>
/// 开启新线程或唤醒线程，去执行回调方法
/// </summary>
/// <param name="w">用回调方法实例化了的委托实例</param>
/// <param name="o">传递给回调方法的参数值</param>
/// <param name="isSuspend">true 表示线程为挂起状态，false 则表示线程还没创建</param>
public void Start(WaitCallback w, Object o, bool isSuspend)
{
//开启新线程或唤醒线程前，先设置
this.w = w;
this.o = o;
//线程为挂起状态，唤醒线程继续执行
if (isSuspend)
{
t.Resume();
}
else
{//线程还没有创建，创建一个新线程，并执行
t = new Thread(new ThreadStart(this.ThreadProc));
t.Start();
}
}
/// <summary>
/// 线程执行的方法
/// </summary>
private void ThreadProc()
{
//死循环，使线程唤醒后不是退出，而是继续通过委托执行回调方法
while (true)
{
//通过委托执行回调方法
w(o);
t.Suspend();
}
}
}
}
3.Test.cs
using System;
using System.Threading;
namespace CustomThreadPool
{
/// <summary>
/// 测试自定义线程池
/// </summary>
class Test
{
/// <summary>
/// 应用程序的主入口点。
/// </summary>
[STAThread]
static void Main(string[] args)
{
//
// TODO: 在此处添加代码以启动应用程序
//
for (int i = 0; i < 5; i++)
{
Console.WriteLine("Start thread {0}", i.ToString());
Thread t = new Thread(new ThreadStart(WorkThread));
t.Start();
}
Console.ReadLine();
Thread.CurrentThread.Abort();
}
public static void WorkThread()
{
for (int i = 0; i < 10; i++)
{
if (i % 2 == 0)
{
if (!ThreadManager.QueueUserWorkItem(new WaitCallback(ThreadProcOne), i, 2000))
{
Console.WriteLine("Failed" + i.ToString());
}
}
else
{
if (!ThreadManager.QueueUserWorkItem(new WaitCallback(ThreadProcTwo), i, 2000))
{
Console.WriteLine("Failed" + i.ToString());
}
}
}
Thread.CurrentThread.Abort();
}
public static void ThreadProcOne(Object stateInfo)
{
Console.WriteLine("Test custom threadpool:" + ((int)stateInfo).ToString());
}
public static void ThreadProcTwo(Object stateInfo)
{
Console.WriteLine("Change work:" + ((int)stateInfo).ToString());
}
}
}
试试其它关键字
　Thread　
同语言下
可能有用的
Dezai.CN贡献的其它代码(4037)