如何在VB.NET中取消Task内的长时间阻塞方法执行？

你的问题很典型：取消令牌的检查被放在了长时间阻塞操作的后面，所以即使你调用了cts.Cancel()，Task线程也得先把DoLongRunningBlockingWork()里的30秒Sleep执行完，才会走到cts.Token.ThrowIfCancellationRequested()这一行，自然没法及时响应取消。

我们需要让取消检查能在阻塞过程中生效，分两种场景处理：

场景1：你可以修改阻塞方法的代码 #

直接让DoLongRunningBlockingWork接受CancellationToken，并在阻塞过程中（或者用支持取消的替代方法）定期检查取消信号：

Public Class DebugForm
    Private Sub DebugForm_Load(sender As Object, e As EventArgs) Handles Me.Load
        Dim cts As New CancellationTokenSource
        Task.Run(Sub()
                     Try
                         DoLongRunningCancellableWork(cts.Token)
                     Catch ex As OperationCanceledException
                         Debug.WriteLine("Task was cancelled!")
                     End Try
                 End Sub, cts.Token)
        ' 1秒后触发取消
        Threading.Thread.Sleep(1000)
        cts.Cancel()
    End Sub

    ' 修改为支持取消的方法
    Private Sub DoLongRunningCancellableWork(token As CancellationToken)
        ' 模拟分阶段的长时间工作，每隔一段时间检查取消
        For i = 0 To 29
            token.ThrowIfCancellationRequested() ' 每次循环前检查取消
            Threading.Thread.Sleep(1000) ' 模拟1秒的工作单元
        Next
        Debug.WriteLine("Completed normally")
    End Sub
End Class

如果想更贴合异步编程的最佳实践，用Task.Delay替代Thread.Sleep会更优雅——它原生支持取消：

Private Async Sub DoLongRunningCancellableWork(token As CancellationToken)
    For i = 0 To 29
        token.ThrowIfCancellationRequested()
        Await Task.Delay(1000, token) ' 原生支持取消的延迟操作
    Next
    Debug.WriteLine("Completed normally")
End Sub

场景2：无法修改阻塞方法（比如是第三方库） #

如果DoLongRunningBlockingWork是你无法修改的黑盒方法，那可以把它放在一个单独的Task中，然后用Task.WhenAny同时等待这个Task和取消信号，这样能让调用方及时响应取消，不用一直等阻塞操作结束：

Public Class DebugForm
    Private Sub DebugForm_Load(sender As Object, e As EventArgs) Handles Me.Load
        Dim cts As New CancellationTokenSource
        Task.Run(Async Sub()
                     Try
                         ' 把阻塞操作包装成独立Task
                         Dim blockingTask = Task.Run(AddressOf DoLongRunningBlockingWork)
                         ' 同时等待阻塞Task完成，或者取消信号触发
                         Await Task.WhenAny(blockingTask, Task.Delay(-1, cts.Token))
                         cts.Token.ThrowIfCancellationRequested() ' 确认是取消触发的终止
                         Await blockingTask ' 如果不是取消，等待阻塞操作完成
                         Debug.WriteLine("Blocking work completed normally")
                     Catch ex As OperationCanceledException
                         Debug.WriteLine("Task was cancelled before blocking work finished")
                         ' 注意：如果是Thread.Sleep这类完全无法中断的操作，底层线程还是会把它执行完
                         ' 我们只能做到让调用方不再等待，无法强行终止阻塞操作
                     End Try
                 End Sub)
        ' 1秒后触发取消
        Threading.Thread.Sleep(1000)
        cts.Cancel()
    End Sub

    Private Sub DoLongRunningBlockingWork()
        Threading.Thread.Sleep(30000)
        Debug.WriteLine("Completed")
    End Sub
End Class

关键注意点 #

• 对于Thread.Sleep这类完全不支持中断的同步阻塞操作，即使触发取消，底层线程还是会把操作执行完——我们能做的只是让调用方及时响应取消，不再等待结果，而非强行终止阻塞。
• 日常开发尽量优先使用原生支持CancellationToken的异步API（比如Task.Delay、HttpClient.GetAsync等），这样取消机制能更顺畅地工作。

内容的提问来源于stack exchange，提问作者JohnWick