C#多线程---委托实现异步

一、概述

通过调用ThreadPool的QueueUserWorkItem方法来来启动工作者线程非常方便，但委托WaitCallback指向的是带有一个参数的无返回值的方法。

如果我们实际操作中需要有返回值，或者需要带有多个参数， 这时通过这样的方式就难以实现， 为了解决这样的问题，我们可以通过委托来建立工作者线程。

异步委托所执行的函数运行在线程池中，属于后台线程。

二、例子

using System;
using System.Threading;

namespace DelegateBeginInvoke
{
    class Program
    {
        delegate string MyDelegate(string str1, string str2);
        static void Main(string[] args)
        {
            MyDelegate del = new MyDelegate(AsyncMethod);
            string str1 = "123";
            string str2 = "456";
           IAsyncResult result =  del.BeginInvoke(str1, str2,null, null);
            Console.WriteLine("Delegate begininvoke called");
            string myResult = del.EndInvoke(result);
            Console.WriteLine($"Result is {myResult}");

        }
        private static string AsyncMethod(string str1, string str2)
        {
            PrintThreadInfo("Print info in AsyncMethod");
            string myString = str1 + str2;
            Thread.Sleep(6000);
            return myString;
        }
        private static void PrintThreadInfo(string info)
        {
            Console.WriteLine(info);
            Console.WriteLine($"ThreadId:{Thread.CurrentThread.ManagedThreadId}
IsBackgroundThread:{Thread.CurrentThread.IsBackground}
IsThreadPoolThread:{Thread.CurrentThread.IsThreadPoolThread}");
            int workerThread = 0;
            int ioThread = 0;
            ThreadPool.GetMaxThreads(out workerThread, out ioThread);
            Console.WriteLine($"MaxWorkerThread:{workerThread}
MaxIoThread:{ioThread}");
            int workerThreadAvailable = 0;
            int ioThreadAvailable = 0;
            ThreadPool.GetAvailableThreads(out workerThreadAvailable, out ioThreadAvailable);
            Console.WriteLine($"AvailableWorkerThread:{workerThreadAvailable}
AvailableIoThread:{ioThreadAvailable}");
        }
    }
}

运行结果如下：

注：EndInvoke会阻塞当前调用线程，直到工作者线程执行完毕，获得结果。