多任務管理類 MutilTaskManager

計算和計算所需的數據能被較為平均的非配到若干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());
 ????????}
 ????}

線程安全版本：

 public?class?MutilTaskManager
 ????{
 ????????private?readonly?int?_maxRun;
 ????????private?readonly?int?_maxQuenen;
 ????????private?List<Task>?_taskRunningList;
 ????????private?readonly?Queue<Task>?_taskQueue;
 ????????private?object?_lockObj?=?new?object();
 ????????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)
 ????????{
 ????????????lock?(_lockObj)
 ????????????{
 ????????????????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)
 ????????{
 ????????????lock?(_lockObj)
 ????????????{
 ????????????????_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
????????}

本文轉自today4king博客園博客，原文鏈接：http://www.cnblogs.com/jinzhao/archive/2012/03/21/2410191.html，如需轉載請自行聯系原作者

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/540168.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/540168.shtml
英文地址，請注明出處：http://en.pswp.cn/news/540168.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！