7

可能重复：
如何中止/取消 TPL 任务？

我有一个需要一些时间来执行的方法，因此我将结果作为回调返回。我的方法看起来像：

public static void DoWork( Action<object> onCompleteCallBack)
{
  Task.Factory.StartNew( () => {
    // Do work
    onCompleteCallBack(someResult);
  });
}

现在我希望能够停止执行该方法，以防用户不想等待。结果，这就是我所制定的：

static void Main ( string[] args )
{            
  var cancelMethod = DoWork( x =>
  {                
    // method completed
    Console.Write( x.ToString() );
  });
  Thread.Sleep( 5000 ); // some time passes 

  // then user decides to abort method
  cancelMethod();
  Console.Read();
}

static Action DoWork ( Action<object> onCompleteCallBack )
{
  bool stopExecuting = false;
  Task.Factory.StartNew( () =>
  {
    for ( var i = 0 ; i < 100000 ; i++ ) 
    {
      Thread.Sleep( 1 );
      if ( stopExecuting )
      {
        onCompleteCallBack( "Method aborted!" );
        return;
      }
    }         
    onCompleteCallBack( "Method completed successfully" );
  } );
  return () => { stopExecuting = true; };
}

什么是中止方法执行的更合适的方法？

编辑

感谢您的回答。我现在记得取消令牌的事情。象征性的东西很难记住。我想我会使用这种方法：

    static void Main ( string[ ] args )
    {
        Action abortTask;

        DoWork( methodCompleted, out abortTask );

        Thread.Sleep( 5000 ); // some time passes then user decides to abort method

        // cancel execution of method
        abortTask( );

        Console.Read( );
    }

    static void methodCompleted ( object msg )
    {            
        Console.Write( msg.ToString( ) );  
    }

    static void DoWork ( Action<object> onCompleteCallBack, out Action abortThisTask )
    {
        bool stopExecuting = false;

        abortThisTask = ( ) => { stopExecuting = true; };

        Task.Factory.StartNew( ( ) =>
        {
            for ( var i = 0 ; i < 100000 ; i++ ) 
            {
                Thread.Sleep( 1 );

                if ( stopExecuting )
                {
                    onCompleteCallBack( "Method aborted!" );
                    return;
                }
            }

            onCompleteCallBack( "Method completed successfully" );
        } );            
    }

    // Overloaded method
    static void DoWork ( Action<object> onCompleteCallBack )
    {
        Action abortTask;
        DoWork( onCompleteCallBack ,out abortTask );
    }

使用你们在这个问题的答案上建议的方法和这种方法会更好吗？我更喜欢这种方法。我认为它比取消令牌更容易阅读。

PS。我的 Visual Studio 放置了很多空间。随意格式化代码:)

4

5 回答 5

4

尝试通过在任务http://blogs.msdn.com/b/csharpfaq/archive/2010/07/19/parallel-programming-task-cancellation.aspx中指定您的函数来使用取消令牌 

CancellationTokenSource tokenSource = new CancellationTokenSource();
 Task.Factory.StartNew( () => {
    // Do work
    onCompleteCallBack(someResult);
  }, tokenSource.Token);

private void cancel_Click(object sender, RoutedEventArgs e)
{
    tokenSource.Cancel();

}
于 2012-11-20T22:05:27.430 回答
1

查看CancellationToken和Albahari 的安全取消线程指南

于 2012-11-20T22:01:51.533 回答
1

接受 CancellationToken 的 StartNew() 方法有一个重载。这是一个示例：http: //msdn.microsoft.com/en-us/library/dd997396.aspx。基础是您创建然后将此令牌传递给您的方法（或从父线程引用它；它是线程安全的）。然后，您的并行方法必须在方便的时候（例如在循环中）检查令牌是否指示任务已被取消。如果是这样，它会优雅地退出。

于 2012-11-20T22:02:05.697 回答
1

任务允许您传入一个CancellationToken. 您可以调用 ct.Cancel() 以设置取消标志。在您的实际执行逻辑中，您可以在某些“检查点”添加检查，以测试if (ct.IsCancellationRequested)并从那里返回方法，或者调用ct.ThrowIfCancellationRequested().

于 2012-11-20T22:05:14.297 回答
0

http://msdn.microsoft.com/en-us/library/dd537607(v=vs.100).aspx可能是一个不错的起点。取决于你要做什么。

于 2012-11-20T22:00:11.677 回答