将 APM 迭代调用转换为 TAP

Question

从MS had said that both APM and EAP are outdated 开始，TAP 是在 .NET Framework 中进行异步编程的推荐方法。然后我想将我的代码从 APM 转换为 TAP：

public class RpcHelper
{
    public void DoReadViaApm(IRpc rpc, BlockingCollection<ArraySegment<byte>> bc)
    {
        byte[] buf = new byte[4096];
        rpc.BeginRead(buf, 0, buf.Length,
            ar =>
            {
                IRpc state = (IRpc) ar.AsyncState;
                try
                {
                    int nb = state.EndRead(ar);
                    if (nb > 0)
                    {
                        bc.Add(new ArraySegment<byte>(buf, 0, nb));
                    }
                }
                catch (Exception ignored)
                {
                }
                finally
                {
                    DoReadViaApm(state, bc);
                }
            }, 
            rpc);
    }

    public void DoReadViaTap(IRpc rpc, BlockingCollection<ArraySegment<byte>> bc)
    {
        Task.Factory.StartNew(() =>
        {
            while (true)
            {
                Task<byte[]> task = rpc.ReadAsync();
                try
                {
                    task.Wait(-1);
                    if (task.Result != null && task.Result.Length > 0)
                    {
                        bc.Add(new ArraySegment<byte>(task.Result));
                    }
                }
                catch (Exception ignored)
                {
                }
            }
        }, TaskCreationOptions.LongRunning);
    }
}

public interface IRpc
{
    IAsyncResult BeginRead(byte[] buffer, int offset, int size, AsyncCallback callback, Object state);
    int EndRead(IAsyncResult asyncResult);

    Task<byte[]> ReadAsync();
}

TAP方法DoReadViaTap()使用TaskCreationOptions.LongRunning，看起来很丑。我可以让 DoReadViaTap() 看起来更像 DoReadViaApm() 吗？

Answer 1

你应该做的是使用async-await。当你这样做时，你不需要启动Task：

public async Task DoReadViaTap(IRpc rpc, BlockingCollection<ArraySegment<byte>> bc)
{
    while (true)
    {
        try
        {
            byte[] result = await rpc.ReadAsync().ConfigureAwait(false);
            if (result != null && result.Length > 0) // or result?.Length > 0 on C# 6
            {
                bc.Add(new ArraySegment<byte>(result));
            }
        }
        catch (Exception ignored)
        {
        }
    }
}

对我来说，这比 APM 版本好得多。

请注意，我不认为完全忽略异常和无法结束它们的无限循环是好的做法，我只是从您的代码中复制了这些。

Answer 2

我不完全确定您的代码应该做什么，但我猜是某个工作人员在等待输入？ 您可以使用await 简化它并使启动的操作异步。请注意，任务有超时，因此您可能需要适当地设置它或捕获异常。

public void DoReadViaTap(IRpc rpc, BlockingCollection<ArraySegment<byte>> bc)
{
    Task.Factory.StartNew(async () =>
    {
        while (true)
        {
            byte[] result = await rpc.ReadAsync();
            if (result.Length > 0)
            {
                bc.Add(new ArraySegment<byte>(result));
            }
            catch (AggregateException ignored)
            {
            }
        }
    }, TaskCreationOptions.LongRunning);
}