对任务执行目标数据

对任务执行目标数据，在实现回调方法时注意加锁控制。

[csharp]

namespace XXXXXXX

{

#region using directives

using System;

using System.Collections.Generic;

using System.Linq;

using System.Threading.Tasks;

#endregion using directives

public class MultiTaskExecutor<T>

{

public delegate void TaskExecutor(IEnumerable<T> assignTaskDataSet);

private readonly object locker = new object();

private readonly int multiTaskNumber;

private List<Task> tasks = new List<Task>();

public MultiTaskExecutor(int multiTaskNumber = 10)

{

this.multiTaskNumber = multiTaskNumber;

}

public void AssignTask(IEnumerable<T> taskDataSet, TaskExecutor taskExecutor)

{

lock (this.locker)

{

if (taskDataSet == null)

{

throw new ArgumentNullException("taskDataSet");

}

if (this.multiTaskNumber < 1)

{

throw new ArgumentException("The value of MultiTaskNumber must be greater than zero.");

}

var taskDataList = taskDataSet as IList<T> ?? taskDataSet.ToList();

if (!taskDataList.Any())

{

return;

}

var taskCount = taskDataList.Count();

var perTaskDataNumber = taskCount/this.multiTaskNumber;

var lastTaskRemainDataNumber = taskCount%this.multiTaskNumber;

this.tasks = new List<Task>();

var currentTaskDataIndex = 0;

for (var taskId = 0; taskId < this.multiTaskNumber; taskId++)

{

// DEBUG

//var debugStartIndex = currentTaskDataIndex;

var assignTaskDataSet = new List<T>();

if (taskId == this.multiTaskNumber - 1)

{

for (var i = 0; i < perTaskDataNumber + lastTaskRemainDataNumber; i++)

{

assignTaskDataSet.Add(taskDataList[currentTaskDataIndex]);

currentTaskDataIndex++;

}

}

else

{

for (var i = 0; i < perTaskDataNumber; i++)

{

assignTaskDataSet.Add(taskDataList[currentTaskDataIndex]);

currentTaskDataIndex++;

}

}

// DEBUG

//Console.WriteLine("Current Task ID: {0}, [{1}, {2})", taskId, debugStartIndex, currentTaskDataIndex);

var task = new Task(() => taskExecutor(assignTaskDataSet));

this.tasks.Add(task);

}

}

}

public async Task Execute()

{

foreach (var task in this.tasks)

{

task.Start();

}

await Task.WhenAll(this.tasks.ToArray());

}

}

}

[/csharp]

查看原文：http://nap7.com/me/multi-task-run-job/