c# - 完成后重新启动数组中的所有任务

Question

我有一组子任务，它们执行一个方法，一旦作业完成，我会收到一个通知并结束。现在我希望他们再次重新开始相同的工作，没有任何麻烦。这怎么可能？

这就是我创建任务数组并使用任务完成的方式：

public void Start()
        {

            this.totalRangePerThread = ((this.endRange - this.startRange) / this.subTasks.Length);

            for (int i = 0; i < this.subTasks.Length; ++i)
            {
                var copy = startRange;
                this.subTasks[i] = new Task(() => searchItem(copy, this.totalRangePerThread), this.token, TaskCreationOptions.LongRunning);
                this.startRange = this.startRange + this.totalRangePerThread;
            }

            //start tasks
            for (int taskIndex = 0; taskIndex < this.subTasks.Length; ++taskIndex)
            {
                    this.subTasks[taskIndex].Start();     
            }
            Task.Factory.ContinueWhenAll(this.subTasks, completedTasks =>
            {
                //write it onto the the activitylog
                if (Form1.Instance != null)
                {
                    Form1.Instance.BeginInvoke((MethodInvoker)delegate
                    {
                        Form1.Instance.AddItemtoActivityLog("Search Completed!");
                    });
                }
            });

        }

我应该再次调用该Start()方法还是有一种机制可以神奇地重新启动子任务？

Answer 1

您可以将用于准备和执行子任务的代码提取到单独的方法中。然后在您的方法中调用它两次Start()：

private void ExecuteSubTasks()
{
    var tasks = new Task[]
        {
            new Task(() => Console.WriteLine("SubTask1 executed.")),
            new Task(() => Console.WriteLine("SubTask2 executed.")),
            new Task(() => Console.WriteLine("SubTask3 executed.")),
        };

    foreach (var task in tasks)
        task.Start();
    Task.WaitAll(tasks);
}

private void Start()
{
    var mainTask = Task.Factory.StartNew(() => ExecuteSubTasks())
        .ContinueWith((prev) =>
        {
            ExecuteSubTasks();
            this.Invoke((MethodInvoker)delegate { MessageBox.Show("Completed."); });
        });
}

Answer 2

public void Start()
{
    var yourTasks = new Task[] {
    Task.Factory.StartNew(_ => task1(),
    Task.Factory.StartNew(_ => task2(),
    Task.Factory.StartNew(_ => ...
    Task.Factory.StartNew(_ => taskN() };
    Task.WaitAll(yourTasks ); // wait for all N tasks to complete
    Start();
}