c#如何取消一个正在执行的方法

本文关键字:方法 执行 一个 何取消 取消 | 更新日期: 2023-09-27 17:54:21

我有一个委托方法在我的应用程序中运行一个繁重的进程(我必须使用MS Framework 3.5):

private delegate void delRunJob(string strBox, string strJob);
执行:

    private void run()
    {
        string strBox = "G4P";
        string strJob = "Test";
        delRunJob delegateRunJob = new delRunJob(runJobThread);
        delegateRunJob.Invoke(strBox, strJob);
    }

在方法的某些部分runJobThread

我调用一个外部程序(SAP -远程函数调用)来检索数据。执行这一行需要1-30分钟。
private void runJobThread(string strBox, string strJob)
{
    // CODE ...
    sapLocFunction.Call(); // When this line is running I cannot cancel the process
    // CODE ...
}

我想允许用户取消整个进程。

如何做到这一点?我尝试了一些方法;但我落在同一点上;

c#如何取消一个正在执行的方法

您必须研究异步和等待机制,而不是使用委托机制。当你理解了这个机制,你就可以转向cancellationtoken了。下面是同时做这两件事的例子:http://blogs.msdn.com/b/dotnet/archive/2012/06/06/async-in-4-5-enabling-progress-and-cancellation-in-async-apis.aspx

好吧;我找到了一个复杂但有效的方法来解决我的问题:

)。我创建了一个"助手应用程序",在进程运行时显示一个通知图标(以确保不干扰主应用程序的正常执行):

private void callHelper(bool blnClose = false)
{
    if (blnClose)
        fw.processKill("SDM Helper");
    else
        Process.Start(fw.appGetPath + "SDM Helper.exe");
}

b。)我创建了一个线程,它只调用重进程线。

c。)当线程是活的,我检查名为"取消"的外部文件("助手应用程序"这样做;当用户单击一个选项来取消进程时,Helper将创建文件)。

d。)如果存在文件;处理所有对象并打破while循环。

e)。方法sapLocFunction.Call()将引发异常,但我希望出现错误。

private void runJobThread(string strBox, string strJob)
{
    // CODE ...
    Thread thrSapCall = new Thread(() =>
    {
        try { sapLocFunction.Call(); }
        catch { /* Do nothing */ }
    });
    thrSapCall.Start();
    while (thrSapCall.IsAlive)
    {
        Thread.Sleep(1000);
        try
        {
            if (fw.fileExists(fw.appGetPath + "''cancel"))
            {
                sapLocFunction = null;
                sapLocTable = null;
                sapConn.Logoff();
                sapConn = null;
                canceled = true;
                break;
            }
        }
        finally { /* Do nothing */ }
    }
    thrSapCall = null;
    // CODE ...
}

工作像一个魅力!

我认为您将不得不求助于这里描述的方法。阅读这篇文章,看看为什么这离理想还有很长的路要走。

private void runJobThread(string strBox, string strJob, CancellationToken token)
{
   Thread t = Thread.CurrentThread;
    using (token.Register(t.Abort))
    {
    // CODE ...
    sapLocFunction.Call(); // When this line is running I cannot cancel the process
    // CODE ...
   } 
}

在nco3.0上显示了一个取消方法

    private readonly static Type RfcConnection = typeof(RfcSessionManager).Assembly.GetType("SAP.Middleware.Connector.RfcConnection");
    
    private readonly static Func<RfcDestination, object> GetConnection = typeof(RfcSessionManager).GetMethod("GetConnection", BindingFlags.Static | BindingFlags.NonPublic).CreateDelegate(typeof(Func<RfcDestination, object>)) as Func<RfcDestination, object>;
    
    private readonly static MethodInfo Cancel = RfcConnection.GetMethod("Cancel", BindingFlags.Instance | BindingFlags.NonPublic);

    object connection = null;
    var completed = true;
    
    using (var task = Task.Run(() => { connection = GetConnection(destination); rfcFunction.Invoke(destination); }))
{  
    try
    {
         completed = task.Wait(TimeSpan.FromSeconds(invokeTimeout));
    
         if (!completed)
             Cancel.Invoke(connection, null);                            
                                
         task.Wait();
    }
    catch(AggregateException e)
    {
         if (e.InnerException is RfcCommunicationCanceledException && !completed)
             throw new TimeoutException($"SAP FM {functionName} on {destination} did not respond in {timeout} seconds.");
         throw;
    }   
}