How to correctly abort a running Matlab function/thread in a .NET Assembly in .NET8?

Question

Andreas Dammann 2024-8-16

1
链接

此问题的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/2145724-how-to-correctly-abort-a-running-matlab-function-thread-in-a-net-assembly-in-net8

回答： Githin George 2024-8-29

Dear MathWorks team

In our .NET Framework 4.7.2 application we instanciate a class from a Matlab .NET assembly and call one function to calculate.

The call is done in a own background thread of the application.

If the calculation takes too long or the calculation request has been canceled, we just aborted the .NET thread with thread.Abort().

.NET core (at least v8) does not support the Abort() function anymore. The only general alternative suggestion I could find is to outsource the call into an own process and then kill the process if required. This seems to be quite complicated and Matlab takes a few seconds to initialize on the first call, which is too slow for us.

Is there any best practice / example how to achieve this?

Thanks in advance

Public Sub New(ByVal theTimeout As Integer, theData As Object, theWorkerMethod As TheWorkerDelegate, theCompleteCallback As CompleteCallbackDelegate, theSynchObj As ISynchronizeInvoke)
    _theData = theData
    _theCompleteCallback = theCompleteCallback
    _theWorkerMethod = theWorkerMethod
    _theSyncObject = theSynchObj
    If theTimeout > 0 Then
      _timeoutTimer = New WcsTimer(theTimeout * 1000, WcsTimer.TimerMode.SingleShot)
      AddHandler _timeoutTimer.TimeElapsed, AddressOf _timeoutTimerElapsed
    End If
    _theThread = New Threading.Thread(AddressOf _startWorkerThread)
    _theThread.Name = "Matlab Supervision Thread"
    _theThread.Start()
  End Sub
  Public Sub Abort()
    _stopTimeoutTimer()
    If _theThread IsNot Nothing AndAlso _theThread.IsAlive Then
      _theThread.Abort()
    End If
    _theThread = Nothing
  End Sub
  Private Sub _startWorkerThread()
    Dim theEx As Exception = Nothing
    Try
      _theWorkerMethod(_theData)    -> Matlab call
    Catch ex As Exception
      theEx = ex
    End Try
    _stopTimeoutTimer()
    Dim p As Object() = {_theData, False, theEx}
    _theSyncObject.Invoke(_theCompleteCallback, p)
  End Sub
  Private Sub _timeoutTimerElapsed(sender As Object, e As EventArgs)
    WcsTrace.Log(WcsTrace.Category.Detailed, $"********* BackgroupWorker Timeoute -> Abort **************")
    Abort()
    _theCompleteCallback(_theData, True, Nothing)
  End Sub

1 个评论
显示 -1更早的评论隐藏 -1更早的评论

Walter Roberson 2024-8-16

Possibly https://learn.microsoft.com/en-us/dotNet/API/system.runtime.controlledexecution?view=net-7.0 ?

请先登录，再进行评论。

请先登录，再回答此问题。

Answer 1

Githin George 2024-8-29

1
链接

此回答的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/2145724-how-to-correctly-abort-a-running-matlab-function-thread-in-a-net-assembly-in-net8#answer_1507179

在 MATLAB Online 中打开

If creating a separate process is not helpful, you could try using Cancellation Token to signal that a task should stop. The task needs to periodically check for this signal and gracefully exit.

The following code shows the usage of the Cancellation Token:

Imports System.Threading
Imports System.Threading.Tasks
Public Class MatlabWorker
    Private _theData As Object    
    Private _theCompleteCallback As CompleteCallbackDelegate
    Private _theWorkerMethod As TheWorkerDelegate
    Private _theSyncObject As ISynchronizeInvoke
    Private _cancellationTokenSource As CancellationTokenSource
    
    Public Sub New(ByVal theTimeout As Integer, theData As Object, theWorkerMethod As TheWorkerDelegate, theCompleteCallback As CompleteCallbackDelegate, theSynchObj As ISynchronizeInvoke)
        
        _theData = theData
        _theCompleteCallback = theCompleteCallback
        _theWorkerMethod = theWorkerMethod
        _theSyncObject = theSynchObj 
        _cancellationTokenSource = New CancellationTokenSource() // Initialize CancellationTokenSource
        If theTimeout > 0 Then    
            _cancellationTokenSource.CancelAfter(theTimeout * 1000) //Set timeout for cancellation
        End If
        
        Task.Run(Sub() _startWorkerTask(_cancellationTokenSource.Token)) // Use Task to start the worker method
    End Sub
    
    
    Public Sub Cancel()  
        _cancellationTokenSource.Cancel() //Request cancellation
    End Sub
    
    
    Private Async Function _startWorkerTask(cancellationToken As CancellationToken) As Task
        Dim theEx As Exception = Nothing
        Try
            Await Task.Run(Sub() _theWorkerMethod(_theData, cancellationToken), cancellationToken) // Pass CancellationToken to the worker method
        Catch ex As OperationCanceledException
            // Handle cancellation
        Catch ex As Exception
            theEx = ex
        End Try
        
        Dim p As Object() = {_theData, cancellationToken.IsCancellationRequested, theEx}
        _theSyncObject.Invoke(_theCompleteCallback, p) // Invoke callback with cancellation status
    End Function
End Class
// Worker method signature should accept a CancellationToken
Public Delegate Sub TheWorkerDelegate(data As Object, cancellationToken As CancellationToken)

Here is an overview of this approach:

Thread Management: Transitioned from Thread to Task for better scalability and resource management.
Cancellation: Introduced a cooperative cancellation model using CancellationToken. We are adding handling for OperationCanceledException to differentiate between cancellations and other exceptions.
Timeout: Simplified timeout handling using CancelAfter.