Thread.Sleep 进入任务

Question

我有以下代码：

    static void Main(string[] args)
    {
        IEnumerable<int> threadsIds = Enumerable.Range(1, 1000);
        DateTime globalStart = DateTime.Now;

        Console.WriteLine("{0:s.fff} Starting tasks", globalStart);
        Parallel.ForEach(threadsIds, (threadsId) =>
        {
            DateTime taskStart = DateTime.Now;
            const int sleepDuration = 1000;
            Console.WriteLine("{1:s.fff} Starting task {0}, sleeping for {2}", threadsId, taskStart, sleepDuration);
            Thread.Sleep(sleepDuration);
            DateTime taskFinish = DateTime.Now;
            Console.WriteLine("{1:s.fff} Ending task {0}, task duration {2}", threadsId, taskFinish, taskFinish- taskStart);

        });
        DateTime globalFinish= DateTime.Now;
        Console.WriteLine("{0:s.fff} Tasks finished. Total duration: {1}", globalFinish, globalFinish-globalStart);
        Console.ReadLine();
    }

目前，当我运行它时，运行它大约需要 60 秒。据我了解，这是因为.Net 不会为每个任务创建一个线程，而是为所有Tasks 创建一些线程，当我执行Thread.Sleep 时，我会阻止该线程执行其他一些任务。

在我的实际情况中，我有一些并行工作要做，如果失败，我必须等待一段时间才能重试。

我正在寻找除 Thread.Sleep 之外的其他东西，这将允许其他任务在其他任务的“睡眠时间”期间运行。

不幸的是，我目前正在运行 .Net 4，这使我无法使用 async 和 await（我想在这种情况下这对我有帮助。

Ps，我得到了相同的结果：

• 把Task.Delay(sleepDuration).Wait()
• 不使用Parallel.Foreach，而是使用Task.Factory.StartNew 的foreach

Ps2，我知道我可以以不同的方式处理我的真实案例，但我很想了解如何以这种方式实现它。

Answer 1

你走在正确的道路上。 Task.Delay(timespan) 是您问题的解决方案。由于你不能使用async/await，你必须多写一点代码才能达到预期的效果。

考虑使用Task.ContinueWith()方法，例如：

Task.Run(() => { /* code before Thread.Sleep */ })
.ContinueWith(task => Task.Delay(sleepDuration)
    .ContinueWith(task2 => { /* code after Thread.Sleep */ }));

您还需要创建一个类以使本地方法变量可以跨子任务访问。

如果你想创建一个在某些条件下每秒运行一次轮询的任务，你可以试试下面的代码：

Task PollTask(Func<bool> condition)
{
    TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>();
    PollTaskImpl(tcs, condition);
    return tcs.Task;
}

void PollTaskImpl(TaskCompletionSource<bool> tcs, Func<bool> condition)
{
    if (condition())
        tcs.SetResult(true);
    else
        Task.Delay(1000).ContinueWith(_ => PollTaskImpl(tcs, condition));
}

不用担心每秒都会创建新任务 - ContinueWith 和 async/await 方法在内部做同样的事情。