等待任务 x 时间并报告进度

Question

我需要一个比 Thread.Sleep 更好的睡眠任务设计，我正在使用 Task 类。

在我的 wpf 应用程序中，我运行一个任务，该任务运行另外几个任务，每个任务首先登录到 Internet 网站，登录后他们需要等待几秒钟并通知用户他们何时会继续进行这是我的问题，因为使用 Thread.Sleep 我无法报告进度。

还有比登录更多的功能，大概有5-6个，都是请求网络资源，而且它们之间需要有一个sleep time 和report send do gui，这5-6个函数都在一个任务，但可能有很多任务。

我需要让任务等待，但也允许它在剩余时间发送更新以继续到 GUI。

你对这个问题有什么想法，如何让它变得更好，也许你已经有一些设计模式来解决这个问题？

我还听说使用 Thread.Sleep 是一种糟糕的设计实践。

编辑：没人知道吗？ 像waithandle、autoresetevent 等带有线程等待的某种自包含定时器是怎么回事？

Answer 1

解决方案是将其视为异步回调，而不是同步等待。 如果您使用 Async CTP，正确的方法是：

async item => { await Task.Delay(1000); Process(item); }

这似乎也是 DataFlow 或 Rx 的理想用例。

使用响应式扩展：

static void Track(int timeout, int frequency, string item)
    {
        Observable.Interval(TimeSpan.FromSeconds(frequency)) //produces 0, 1, 2.. with the interval
                  .Do(i => Console.WriteLine("Working on {0}", item)) // work on item
                  .TakeUntil(Observable.Timer(TimeSpan.FromSeconds(timeout))) //stop once the timer publishes a value
                  .Subscribe
                  (
                        i => Console.WriteLine("Reporting {0}%", ((double)(i + 1) / timeout * 100)), // the interval reaches OnNext
                        e => Console.WriteLine("Error!"), // error occured 
                        () => Console.WriteLine("Completed") // observable completed
                  );
    }

使用Track(timeout: 5, frequency: 1, item: "http://example.com/?") 调用它时，产生的输出是：

Working on http://example.com/?
Reporting 20%
Working on http://example.com/?
Reporting 40%
Working on http://example.com/?
Reporting 60%
Working on http://example.com/?
Reporting 80%
Completed

Answer 2

忘记使用 Thread.Sleep。相反，在后台线程中运行您的任务并使用带有 AutoResetEvent 的 WaitHandle。 （链接：WaitHandle/WaitOne/AutoReset）

您的后台线程可以使用异步委托向 UI 发送更新，但调用线程将等待它，直到任何事情发生：

1) 您的线程使用 yourwaithandle.Set() 报告它已完成任务；

或

2) 等待线程超时（超时值设置为 WaitOne() 方法的参数）。

Answer 3

与其让一个任务执行所有这些六个功能（登录等），不如让每个功能成为一个单独的任务。然后，您可以创建一个按时间排序的优先级队列。当您想要启动其中一个元任务时，您将其第一个函数与状态数据（即 url、用户 ID、密码等）一起放入队列中。

当每个功能完成时，它会将下一个要执行的功能排入队列。因此，如果前两个函数是 login 和 get_data，您将拥有：

queue login with state data to execute at DateTime.Now
When login is finished, it queues get_data with the state data and DateTime.Now + 5 seconds (or whatever time)

当最后一个函数执行时，它会将结果发布到某处。

然后，您可以设置一个计时器，该计时器将每秒轮询队列 10 次（或者在将某些内容添加到队列时更新计时器的下一个滴答时间）。它可以根据需要启动单个任务。

新的 Async CTP 可能已经有了这种东西：“定时执行任务”。可能值得研究一下。

关于报告进度，每个功能都可以在启动时报告进度（即“登录”......“等待5秒获取数据”......“获取数据”等）如果你愿意，你可以使计时器线程定期遍历优先级队列并报告何时执行特定任务。虽然这可能有点矫枉过正。

您听到的是正确的：Thread.Sleep 是一个非常糟糕的主意，尤其是当您使用线程池线程时。

Answer 4

您是否考虑过使用计时器（来自 System.Timers）来执行插页式“剩余时间”消息更新？您的每个任务都可以设置预期的完成时间值，然后您的计时器任务可以负责倒计时并根据需要更新 UI。不需要 Thread.Sleep，Timer 将在线程池线程上执行其 Tick 代码。