我们有一个基于.NET Remoting的旧版应用程序。我们的客户端客户端库目前仅支持同步操作。我想使用基于TPL的async Task<>
方法添加异步操作。
作为概念验证,我已经基于these instructions的修改版建立了一个基本的远程服务器/客户端解决方案。
我还发现this article描述了如何将基于APM的异步操作转换为基于TPL的异步任务(使用Task.Factory.FromAsync
)
我不确定的是我是否被迫在.BeginInvoke()
中指定回调函数以及是否在.EndInvoke()
中指定。如果两者都需要,则回调函数和.EndInvoke()
之间的区别到底是什么?如果只需要一个,则应使用哪一个返回值,并确保我have no memory leaks。
这是我当前的代码,在该代码中我没有将回调传递给.BeginInvoke()
:
public class Client : MarshalByRefObject
{
private IServiceClass service;
public delegate double TimeConsumingCallDelegate();
public void Configure()
{
RemotingConfiguration.Configure("client.exe.config", false);
var wellKnownClientTypeEntry = RemotingConfiguration.GetRegisteredWellKnownClientTypes()
.Single(wct => wct.ObjectType.Equals(typeof(IServiceClass)));
this.service = Activator.GetObject(typeof(IServiceClass), wellKnownClientTypeEntry.ObjectUrl) as IServiceClass;
}
public async Task<double> RemoteTimeConsumingRemoteCall()
{
var timeConsumingCallDelegate = new TimeConsumingCallDelegate(service.TimeConsumingRemoteCall);
return await Task.Factory.FromAsync
(
timeConsumingCallDelegate.BeginInvoke(null, null),
timeConsumingCallDelegate.EndInvoke
);
}
public async Task RunAsync()
{
var result = await RemoteTimeConsumingRemoteCall();
Console.WriteLine($"Result of TPL remote call: {result} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
}
}
public class Program
{
public static async Task Main(string[] Args)
{
Client clientApp = new Client();
clientApp.Configure();
await clientApp.RunAsync();
Console.WriteLine("Press any key to continue...");
Console.ReadKey(false);
}
}
最佳答案
回调函数和.EndInvoke()
之间的区别在于,回调将在线程池中的任意线程上执行。如果必须确保从与调用BeginInvoke相同的线程上的读取中获得结果,则不应使用回调,而应轮询IAsyncResult对象并在操作完成后调用.EndInvoke()
。
如果您在.EndInvoke()
之后立即调用.Beginnvoke()
,则会阻塞线程,直到操作完成。这将起作用,但是扩展性很差。
因此,您所做的一切似乎没问题!