多任务管理类 MutilTaskManager代码,CSharp代码库,德仔网

代码语言

代码分类

【CSharp】多任务管理类 MutilTaskManager

作者:today / 发布于2013/6/17/ 486

计算和计算所需的数据能被较为平均的非配到若干task的时候，下面的任务管理类可以提供在大数据大计算量的情况下非精确的控制task的执行数量来限制计算量和内存占用量.


	public class MutilTaskManager
	 {
	 private readonly int _maxRun;
	 private readonly int _maxQuenen;
	 private List<Task> _taskRunningList;
	 private readonly Queue<Task> _taskQueue;

	 public bool IsQueueFull
	 {
	 get { return _taskQueue.Count > _maxQuenen; }
	 }

	 public MutilTaskManager(int maxRun = 8, int maxQuenen = 2)
	 {
	 _maxRun = maxRun;
	 _maxQuenen = maxQuenen;
	 _taskRunningList = new List<Task>(maxRun);
	 _taskQueue = new Queue<Task>(2);
	 }

	 public void TakeBooting(int sleepTime = 10)
	 {
	 if (_taskRunningList.Count >= _maxRun)
	 {
	 _taskRunningList = _taskRunningList.Where(it => !it.IsCompleted).ToList();
	 }
	 while (_taskRunningList.Count < _maxRun && _taskQueue.Count > 0)
	 {
	 var t = _taskQueue.Dequeue();
	 _taskRunningList.Add(t);
	 t.Start();
	 }
	 System.Threading.Thread.Sleep(sleepTime);
	 }

	 public void Enqueue(Task task)
	 {
	 _taskQueue.Enqueue(task);
	 TakeBooting(0);
	 }

	 public void WaitAll()
	 {
	 while (_taskQueue.Count > 0)
	 {
	 TakeBooting();
	 }
	 Task.WaitAll(_taskRunningList.ToArray());
	 }
	 }

	使用示例：

	void Test()
	 {
	 var mtm = new MutilTaskManager();
	 foreach(int i in(new int[10]))
	 {
	 while (mtm.IsQueueFull)
	 {
	 mtm.TakeBooting();
	 }
	 mtm.Enqueue(new Task(myTask));
	 }
	 }

	 void myTask()
	 {
	 //read data
	 //do something
	 }

试试其它关键字

　多任务管理　

同语言下

可能有用的

today贡献的其它代码(7)