如何在 C# 中将 HttpClient PostAsync() 与线程池一起使用？

Question

我正在使用以下代码将图像发布到服务器。

var image= Image.FromFile(@"C:\Image.jpg");
Task<string> upload = Upload(image);
upload.Wait();

public static async Task<string> Upload(Image image)
{
    var uriBuilder = new UriBuilder
    {
        Host = "somewhere.net",
        Path = "/path/",
        Port = 443,
        Scheme = "https",
        Query = "process=false"
    };

    using (var client = new HttpClient())
    {
        client.DefaultRequestHeaders.Add("locale", "en_US");
        client.DefaultRequestHeaders.Add("country", "US");

        var content = ConvertToHttpContent(image);
        content.Headers.ContentType = MediaTypeHeaderValue.Parse("image/jpeg");

        using (var mpcontent = new MultipartFormDataContent("--myFakeDividerText--")
            {
                {content, "fakeImage", "myFakeImageName.jpg"}
            }
        )
        {
            using (
                var message = await client.PostAsync(uriBuilder.Uri, mpcontent))
            {
                var input = await message.Content.ReadAsStringAsync();
                return "nothing for now";
            }
        }
    }
}

我想修改此代码以运行多个线程。我之前使用过“ThreadPool.QueueUserWorkItem”并开始修改代码以利用它。

private void UseThreadPool()
{
    int minWorker, minIOC;
    ThreadPool.GetMinThreads(out minWorker, out minIOC);
    ThreadPool.SetMinThreads(1, minIOC);

    int maxWorker, maxIOC;
    ThreadPool.GetMaxThreads(out maxWorker, out maxIOC);
    ThreadPool.SetMinThreads(4, maxIOC);

    var events = new List<ManualResetEvent>();

    foreach (var image in ImageCollection)
    {
        var resetEvent = new ManualResetEvent(false);
        ThreadPool.QueueUserWorkItem(
            arg =>
            {
                var img = Image.FromFile(image.getPath());
                Task<string> upload = Upload(img);
                upload.Wait();
                resetEvent.Set();
            });
        events.Add(resetEvent);

        if (events.Count <= 0) continue;

        foreach (ManualResetEvent e in events) e.WaitOne();
    }
}

问题是由于调用“upload.Wait()”，一次只能执行一个线程。所以我仍然按顺序执行每个线程。我不清楚如何将 PostAsync 与线程池一起使用。

如何通过调整上面的代码使用多线程将图像发布到服务器？ HttpClient PostAsync 是最好的方法吗？

Answer 1

我想修改此代码以运行多个线程。

为什么？线程池只能用于 CPU 密集型工作（当然还有 I/O 完成）。

您可以使用async 进行并发处理：

var tasks = ImageCollection.Select(image =>
{
  var img = Image.FromFile(image.getPath());
  return Upload(img);
});
await Task.WhenAll(tasks);

请注意，我删除了您的 Wait。您应该避免将Wait 或Result 与async 任务一起使用；请改用await。是的，这将导致async 在您的代码中增长，您应该“一直”使用async。