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
private void runJobThread(string strBox, string strJob)
{
// CODE ...
sapLocFunction.Call(); // When this line is running I cannot cancel the process
// CODE ...
}
我想允许用户取消整个进程。
如何做到这一点?我尝试了一些方法;但我落在同一点上;
您必须研究异步和等待机制,而不是使用委托机制。当你理解了这个机制,你就可以转向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;
}
}