异步调用 WCF 服务并在新任务中等待它

Question

我是基于任务的编程的新手。我必须异步调用 WCF 服务并启动一个任务来等待它，因为我不想在相同的方法中等待，所以我编写了类似这样的代码

void MyMainMethod()
{
   for(int j=0;j<10; j++)
   {

      int I = 100;
      Task<response> res =  _client.GetValueAsnc(request);

       //Do some work

       Task.Run(()=> WaitForResponse(res , I));
    }
}

Async Task WaitForResponse(Task<response> res , int I)
{
   await res;

   if(res.responsecode == "Success")
   {
      //udatateDB...
   }
 
   else
   {
      //update DB with Error Message..
   }
}

这样，如果我在一个循环中调用此服务 10 次，它将启动 10 个任务并给我响应，而不是在 MyMainMethod() 中等待响应，我将为每个请求启动一个单独的任务。

如果这是正确的方法，或者我在这里犯了一些重大错误，并且如果我需要更多细节来解释这个问题，请告诉我。

提前致谢。

Answer 1

您尝试实现的目标是一件好事。不阻塞某个主线程是个好主意，而且你这样做的方式会奏效。

但是，如果你这样做，你必须手动控制任务的数量。您可能不希望这个数字太高，否则过多的并行性可能会影响性能。

.net 中有一些类可以通过所谓的线程池来帮助管理任务队列。 您使用已知的最大线程数配置线程池，然后将任务排队到池中。线程池类负责清空队列并将任务分配给池中的空闲线程。

您可以了解更多关于线程池的信息here on ms docs

以下示例来自 MS 文档网站。

using System;
using System.Threading;

public class Example 
{
    public static void Main() 
    {
        // Queue the task.
        ThreadPool.QueueUserWorkItem(ThreadProc);
        Console.WriteLine("Main thread does some work, then sleeps.");
        Thread.Sleep(1000);

        Console.WriteLine("Main thread exits.");
    }

    // This thread procedure performs the task.
    static void ThreadProc(Object stateInfo) 
    {
        // No state object was passed to QueueUserWorkItem, so stateInfo is null.
        Console.WriteLine("Hello from the thread pool.");
    }
}
// The example displays output like the following:
//       Main thread does some work, then sleeps.
//       Hello from the thread pool.
//       Main thread exits.

Answer 2

为什么不在线程池上使用任务并行库。

class Client
{
    internal async Task<string> GetValueAsnc()
    {
        Console.WriteLine("GetValueAsync");
        await Task.Delay(TimeSpan.FromSeconds(2));
        return "success";
    }
}
class Program
{
    private static readonly Client _client = new Client();

    static void Main(string[] args)
    {
        var tasks = new List<Task>();
        for (int j = 0; j < 10; j++)
        {
            tasks.Add(WaitForResponse());
        }

        Task.WhenAll(tasks);
        Console.WriteLine("Tasks finished");
        Console.ReadLine();
    }

    static async Task WaitForResponse()
    {
        var res = await _client.GetValueAsnc();

        if (res == "Success")
        {
            //udatateDB...
        }

        else
        {
            //update DB with Error Message..
        }
    }
}

它有比ThreadPool更好的api，这样不用担心线程饥饿