使用任务工厂和回调创建异步方法

本文关键字：回调 创建 异步方法 工厂 任务 | 更新日期: 2023-09-27 18:16:39

我开始创建一些将触发异步操作的类，我希望客户端注册回调以接收一些结果。最后，我找到了下面的代码。这只是一个例子，我想知道是否有更好的方法使用TaskFactory和Action<>, Func<>

下面是客户端基本示例: 
Client client2 = new Client();
client2.GetClientList(ClientCallBack);

private static void ClientCallBack(List<Client> listado)
{ 
  //Receive the list result and do some stuff in UI      
}

下面是客户端类GetCLientList异步示例:

public void GetClientList(Action<List<Client>> Callback)
{
  List<Client> listado=null;
  Task.Factory.StartNew(() =>
    {
      listado = new List<Client>{
        new Client{ apellidos="Landeras",nombre="Carlos",edad=25},
        new Client{ apellidos="Lopez", nombre="Pepe", edad=22},
        new Client{ apellidos="Estevez", nombre="Alberto", edad=28}
      };
    //Thread.Sleep to simulate some load
    System.Threading.Thread.Sleep(4000);
  }).ContinueWith((prevTask) =>
    {
      Callback(listado);
    }
  );
}

有更好的方法吗?我知道我可以从我的函数返回Task，并在客户端注册continueWith，但我想把它包装在类内。

编辑

我在张贴另一个例子。我试图使sync/async版本的webrequest。这种方法正确吗?: 

public string ExecuteRequest(string url)
{
  HttpWebRequest httpwebrequest = (HttpWebRequest) WebRequest.Create(url);
  HttpWebResponse httpwebresponse = (HttpWebResponse) httpwebrequest.GetResponse();
  using (StreamReader sr = new StreamReader(httpwebresponse.GetResponseStream()))
  {
    return sr.ReadToEnd();
  }
}
public void ExecuteRequestAsync(string uri,Action<string> callbackResult)
{
  Task.Factory.StartNew(() => ExecuteRequest(uri), CancellationToken.None)
    .ContinueWith((task) => callbackResult(task.Result));           
}

使用任务工厂和回调创建异步方法

首先，您的方法看起来实际上并不是异步的，因此您不会从使它看起来像异步中获得太多好处。如果你的方法的用户决定在另一个线程上运行它，他们可以自己执行。

第二，如果你可以使用c# 5.0，你应该遵循基于任务的异步模式，使你的方法更容易使用。这样(假设您有理由忽略上面的第一点)，您的代码可能看起来像这样:

public Task<List<Client>> GetClientListAsync()
{
    return Task.Run(() =>
    {
        var list = new List<Client>
        {
            new Client { apellidos="Landeras", nombre="Carlos", edad=25 },
            new Client { apellidos="Lopez", nombre="Pepe", edad=22 },
            new Client { apellidos="Estevez", nombre="Alberto", edad=28 }
        };
        //Thread.Sleep to simulate some load
        System.Threading.Thread.Sleep(4000);
        return list;
    });
}

或者，如果你想让你的代码真正异步:

public async Task<List<Client>> GetClientListAsync()
{
    var list = new List<Client>
    {
        new Client { apellidos="Landeras", nombre="Carlos", edad=25 },
        new Client { apellidos="Lopez", nombre="Pepe", edad=22 },
        new Client { apellidos="Estevez", nombre="Alberto", edad=28 }
    };
    //Task.Delay() to simulate some load
    await Task.Delay(4000);
    return list;
}

在这两种情况下，您都可以使用此方法，而无需使用async方法的回调，如:

var client = new Client();
var list = await client.GetClientListAsync();
//Receive the list result and do some stuff in UI

第三，如果你不想(或不能)使用async - await，那么你的代码很接近，但很正确。问题是回调实际上不会在UI线程上执行。为此，您需要使用TaskScheduler.FromCurrentSynchronizationContext() .

此外，你的设计，其中Client有一个GetClientList()方法对我来说似乎很可疑。这样的方法可能属于某种存储库对象，而不是Client。

相关文章：