聊聊多线程那一些事儿 之 四 经典应用（取与舍、动态创建）

static void Main(string[] args)
{
    Console.WriteLine("开始获取酒店数据......");
// 获取最新的客房信息(假设最大等待时间为1S)
    List<string> listHotelRoomInfro = GetHotelRoomInfro(1000);
    Console.WriteLine("获取酒店数据获取完毕,获取到的数据为：");
foreach (var item in listHotelRoomInfro)
    {
        Console.WriteLine(item);
    }
    Console.ReadLine();
 }
 
/// <summary>
/// 获取最新的客房信息
/// </summary>
/// <param name="maxWaitTimes">最大获取时间（也就是舍弃时间），单位毫秒</param>
/// <returns>客房信息集合</returns>
private static List<string> GetHotelRoomInfro(int maxWaitTimes)
 {
// 模拟存储获取到的酒店客房数据集合
     List<string> listHotelRoomInfro = new List<string>();
// 在此我也分别对3种不同渠道，采用3种不同的方式来实现
// 其一、通过传统的 new 方式来实例化一个task对象，获取 携程 的客房数据
     Task newCtripTask = new Task(() =>
    {
// 具体获取业务逻辑处理...
         Thread.Sleep(new Random().Next(100, 999));
        listHotelRoomInfro.Add("我是来自 携程 的最新客房信息");
    });
// 启动 tsak
     newCtripTask.Start();
// 其二、通过工厂 factory 来生成一个task对象，并自启动：获取 艺龙 的客房数据
     Task factoryElongTask = Task.Factory.StartNew(() =>
     {
// 具体获取业务逻辑处理...
         Thread.Sleep(new Random().Next(555, 1500));
         listHotelRoomInfro.Add("我是来自 艺龙 的最新客房信息");
     });
// 其三、通过 Task.Run(Action action) 来创建一个自启动task：获取 去哪儿网 的客房数据
     Task runQunarTask = Task.Run(() =>
     {
// 具体获取业务逻辑处理...
         Thread.Sleep(new Random().Next(1100, 2000));
         listHotelRoomInfro.Add("我是来自 去哪儿网 的最新客房信息");
     });
// 等待获取接口，阻塞主流程，如果 在 指定的时间 maxWaitTimes未返回数据的接口方直接舍弃掉
     Task.WaitAll(new Task[] { newCtripTask, factoryElongTask, runQunarTask }, maxWaitTimes);
return listHotelRoomInfro;
 }

class Program
 {
     /// <summary>
     /// 最多允许创建的线程数，可以通过配置文件来配置
     /// 具体的值也该是由：服务器资源+接口限制等多因数来确定的
     /// </summary>
     public static int maxThread = 10;
     static void Main(string[] args)
     {
         // 假设选择处理20条酒店数据
         List<string> listHotel = new List<string>();
         for (int i = 0; i < 20; i++)
         {
             listHotel.Add($"我是酒店{(i + 1).ToString().PadLeft(2, '0')}");
         }

         // 创建Tsak处理酒店数据同步
         AsyncDynamicSynchronouslyHotel(listHotel);

         Console.ReadLine();
     }

     /// <summary>
     /// 根据酒店数据量，动态创建Tsak来处理酒店数据同步
     /// </summary>
     /// <param name="listHotel">待处理的酒店数据列表</param>
     private static void AsyncDynamicSynchronouslyHotel(List<string> listHotel)
     {
         object hotelTaskLock = new object();

         // 先做一个非空判断
         if (listHotel == null || listHotel.Count < 1)
         {
             return;
         }

         // task线程数组
         List<Task> taskList = new List<Task>();

         // 首先根据资源数据量+最大允许线程数来确定需要开启的线程
         int taskCount = listHotel.Count < maxThread ? listHotel.Count : maxThread;

         // 创建指定是task线程数
         for (int i = 0; i < taskCount; i++)
         {
             // 创建一个task线程
             taskList.Add(new Task(() =>
             {
                 while (listHotel != null && listHotel.Count > 0)
                 {
                     // 给该线程分配一个酒店处理任务
                     string hotelInfro = string.Empty;

                     // 线程通过，加一个资源锁
                     lock (hotelTaskLock)
                     {
                         // 在获取到锁后，还需要做一个资源判断，避免获取到锁后，资源以及被消耗完毕
                         if (listHotel != null && listHotel.Count > 0)
                         {
                             hotelInfro = listHotel[0];
                             listHotel.Remove(hotelInfro);
                         }
                     }

                     // 开始模拟真正的数据同步操作
                     if (!string.IsNullOrEmpty(hotelInfro))
                     {
                         Thread.Sleep(1000);
                         Console.WriteLine($"我是线程ID{Thread.CurrentThread.ManagedThreadId.ToString()  }，完成酒店【{hotelInfro}的数据同步处理");
                     }
                 }
             }));

             // 启动线程
             taskList[i].Start();
         }
     }
 }