14

如何停止长时间运行的任务（.net 4）？

我已经实现了 TPL 并尝试使用，CancellationTokenSource但它似乎不适用于我的场景。我见过的所有示例都假设您在 while 循环中进行工作，以便您可以检查任务是否已被取消，而我只有一个需要很长时间的操作。我不能等待工作完成，因为我需要假设它可能永远不会完成。这是我尝试过的代码：

bool? result = null;

var cs = new CancellationTokenSource();
var ct = cs.Token;

var doWorkTask = new Task(() =>
{
    Console.WriteLine("start dowork task");

    result = Work.LongRunning();
 }, ct);

doWorkTask.Start();

Task.WaitAny(new Task[] { doWorkTask }, timetowait);

if (doWorkTask.IsCompleted)
{
    Console.WriteLine("dowork task completed");

    doWorkTask.Dispose();
}
else
{
    Console.WriteLine("dowork task has timedout");

    cs.Cancel();

    throw new TimeoutException("Timeout hit.");
}

代码有效，但如果发生超时并且正在完成的工作访问“非托管代码”即资源，则永远不会处理任务。那就是说IsCancelledRequested不能使用Work.LongRunning()所以我不能ThrowIfCancellationRequested。

我对其他想法持开放态度，我也尝试过BackgroundWorker，但这似乎也不合适。

新示例：

var service = new System.ServiceProcess.ServiceController(ServiceName, ServerName);

var serviceTask = Task.Factory.StartNew(() =>
{
    result = (service.Status == ServiceControllerStatus.Running
         || service.Status == ServiceControllerStatus.StartPending);
}, cs.Token);

serviceTask.Wait(2000, cs.Token);

if (!serviceTask.IsCompleted)
{
    cs.Cancel();
}
4

2 回答 2

4

这是上面描述的选项 1 的示例（即只是在没有信号取消的情况下杀死任务） 

class Program
    {
        private static void Main(string[] args)
        {
            Test test = new Test();
            test.Run();

            Console.WriteLine("Type c to cancel");
            if (Console.ReadLine().StartsWith("c"))
            {
                Console.WriteLine("cancellation requested");
                test.CancellationTokenSource.Cancel();
            }

            Console.ReadLine();
        }
    }

    public class Test
    {
        private void DoSomething()
        {
            Console.WriteLine("DoSomething runs for 30 seconds ");
            Thread.Sleep(new TimeSpan(0, 0, 0, 30));
            Console.WriteLine("woke up now ");
        }

        public CancellationTokenSource CancellationTokenSource = new CancellationTokenSource();

        public void Run()
        {
                var generateReportsTask = Task.Factory.StartNew(() =>
                {
                    CancellationTokenSource.Token.ThrowIfCancellationRequested();
                    Task doSomething = new Task(DoSomething, CancellationTokenSource.Token);
                    doSomething.Start();

                    doSomething.Wait(CancellationTokenSource.Token);
                }, CancellationTokenSource.Token);

                generateReportsTask.ContinueWith(
                    (t) =>
                    {
                        if (t.Exception != null)
                            Console.WriteLine("Exceptions reported :\n " + t.Exception);

                        if (t.Status == TaskStatus.RanToCompletion)
                            Console.WriteLine("Completed report generation task");
                        if (t.Status == TaskStatus.Faulted)
                            Console.WriteLine("Completed reported generation with unhandeled exceptions");
                        if(t.Status == TaskStatus.Canceled)
                            Console.WriteLine("The Task Has been cancelled");
                    });

        }
    }
于 2015-02-05T17:26:50.147 回答
2

任务并行库专为 CPU 密集型工作而设计。CPU 密集型工作一会儿就完成了。如果您的 Work.LongRunning() 是 CPU 密集型的，您应该能够在内部传递取消令牌并取消它。如果它不是 CPU 密集型的，那么您可以简单地在最终回调中丢弃结果，而不必担心停止实际工作，因为它只是在等待。

顺便说一句，如果您等待（数据库调用或其他），您可能在底部某处有异步方法。您可以显示 Begin/End 模式并将其包装在任务中。这个问题解释了如何：TPL TaskFactory.FromAsync vs Tasks with blocking methods这样你就可以避免占用通用线程，因为IO等待是以操作系统处理的特殊方式完成的。

于 2012-05-02T07:24:43.310 回答