計(jì)算和計(jì)算所需的數(shù)據(jù)能被較為平均的非配到若干task的時(shí)候，下面的任務(wù)管理類可以提供在大數(shù)據(jù)大計(jì)算量的情況下非精確的控制task的執(zhí)行數(shù)量來(lái)限制計(jì)算量和內(nèi)存占用量.

?

下面是代碼（非線程安全版本）：

?

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
????????}

?

?

本文轉(zhuǎn)自today4king博客園博客，原文鏈接：http://www.cnblogs.com/jinzhao/archive/2012/03/21/2410191.html，如需轉(zhuǎn)載請(qǐng)自行聯(lián)系原作者

總結(jié)

以上是生活随笔為你收集整理的多任务管理类 MutilTaskManager的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。