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

代码语言

代码分类

【CSharp】多任务管理类 MutilTaskManager

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

计算和计算所需的数据能被较为平均的非配到若干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)