线程管理器，会开启或唤醒一个线程去执行指定的回调方代码,CSharp代码库,德仔网

代码语言

代码分类

【CSharp】线程管理器，会开启或唤醒一个线程去执行指定的回调方

作者:Dezai.CN / 发布于2012/12/6/ 479

ThreadManager.cs
using System;
using System.Threading;
using System.Collections;
namespace CustomThreadPool
{
/// <summary>
/// 线程管理器，会开启或唤醒一个线程去执行指定的回调方法
/// </summary>
public class ThreadManager
{
private static ArrayList threadList = new ArrayList(); //线程列表，静态
//不允许创建实例
private ThreadManager()
{
}
/// <summary>
/// 静态方法，开启或唤醒一个线程去执行指定的回调方法
/// </summary>
/// <param name="waitCallback">委托实例</param>
/// <param name="obj">传递给回调方法的参数</param>
/// <param name="timeOut">当没有可用的线程时的等待时间，以毫秒为单位</param>
/// <returns></returns>
public static bool QueueUserWorkItem(WaitCallback waitCallback, Object obj, int timeOut)
{
//锁住共享资源，实现线程安全
lock(threadList)
{
try
{
//如果线程列表为空，填充线程列表
if (threadList.Count == 0)
{
InitThreadList();
}
long startTime = DateTime.Now.Ticks;
do
{
//遍历线程列表，找出可用的线程
foreach(MyThread myThread in threadList)
{
//线程为空，需要创建线程
if (myThread.T == null)
{
myThread.Start(waitCallback, obj, false);
return true;
}
else if (myThread.T.ThreadState == ThreadState.Suspended)
{//线程为挂起状态，唤醒线程
myThread.Start(waitCallback, obj, true);
return true;
}
}
//在线程 Sleep 前释放锁
Monitor.PulseAll(threadList);
Thread.Sleep(500);
}while (((DateTime.Now.Ticks - startTime) / 10000) < timeOut);
}
finally
{
Monitor.Exit(threadList);
}
}
return false;
}
//使用 MyThread 对象填充线程列表，注意，这个时候线程并没有启动
private static void InitThreadList()
{
threadList = new ArrayList();
for (int i = 0; i < 10; i++)
{
MyThread t = new MyThread();
threadList.Add(t);
}
}
}
}

试试其它关键字

　线程管理器　

同语言下

可能有用的

Dezai.CN贡献的其它代码(4037)