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

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&#91;currentTaskDataIndex&#93;);
                            currentTaskDataIndex++;
                        }
                    }
                    else
                    {
                        for (var i = 0; i < perTaskDataNumber; i++)
                        {
                            assignTaskDataSet.Add(taskDataList&#91;currentTaskDataIndex&#93;);
                            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());
        }
    }
}