/// <summary>/// 高效多线程测试/// </summary>public class ThreadTestController : ApiController{static AutoResetEvent autoResetEvent = new AutoResetEvent(false);private static string keySet = System.Configuration.ConfigurationManager.AppSettings["KeySetting"];/// <summary>/// 多线程运行 -- 线程池/// </summary>/// <returns></returns>public ApiReponseBaseModel MultThreads(){ApiReponseBaseModel result = new ApiReponseBaseModel();List<string> list = new List<string>() { "一", "二", "三", "四", "", "五", "六", "七" };ApiReponseBaseModel masterVal = new ApiReponseBaseModel() { Id = 1, Success = false, Message = "one" };List<string> newList = new List<string>();try{int i = 0;foreach (var item in list){try{if (item == "四") throw new Exception("人造异常");ThreadPool.QueueUserWorkItem(new WaitCallback(delegate (object obj){if (string.IsNullOrEmpty(item)) { i++; newList.Add((i).ToString() + ":" + "为空了"); return; }  //保证每个子线程都有执行 i++try{#region ApiReponseBaseModel val = new ApiReponseBaseModel{Id = masterVal.Id,Success = masterVal.Success,Message = masterVal.Message};#endregionval.Message = item;Thread.Sleep(500);lock (newList){newList.Add(i.ToString() + ":" + val.Message);}}catch (Exception ex){newList.Add((i+1).ToString() + ":" + ex.Message);}finally{if (++i == list.Count) autoResetEvent.Set();}}), null);}catch (Exception ex){i++;    //发生异常，一定要记得 i++newList.Add(i.ToString() + ":" + ex.Message);continue;}//finally  //【误区】千千万万不要在这里写逻辑判断（i == list.Count 或者写 i++），这个finally是主线程的，不一定会在子线程之后执行的//{//    i++;//    if (i == list.Count) autoResetEvent.Set();//}
                }autoResetEvent.WaitOne();newList.Add("the end");result.Data = newList;}catch (Exception ex){throw ex;}return result;}/// <summary>/// 单线程运行/// </summary>/// <returns></returns>public ApiReponseBaseModel SingleThread(){ApiReponseBaseModel result = new ApiReponseBaseModel();List<string> list = new List<string>() { "一", "二", "三", "四", "", "五", "六", "七" };ApiReponseBaseModel masterVal = new ApiReponseBaseModel() { Id = 1, Success = false, Message = "one" };List<string> newList = new List<string>();int i = 0;foreach (var item in list){if (string.IsNullOrEmpty(item)) { i++; newList.Add((i).ToString() + ":" + "为空了"); continue; }#region ApiReponseBaseModel val = new ApiReponseBaseModel{Id = masterVal.Id,Success = masterVal.Success,Message = masterVal.Message};#endregionval.Message = item;Thread.Sleep(500);newList.Add(i.ToString() + ":" + val.Message);i++;}newList.Add("the end");result.Data = newList;return result;}}

        /// <summary>/// 多线程运行 -- 任务工厂/// </summary>/// <returns></returns>public ApiReponseBaseModel TaskFactory(){ApiReponseBaseModel result = new ApiReponseBaseModel();List<string> list = new List<string>() { "一", "二", "三", "四", "", "五", "六", "七" };ApiReponseBaseModel masterVal = new ApiReponseBaseModel() { Id = 1, Success = false, Message = "one" };List<string> newList = new List<string>();List<Task> taskList = new List<Task>();int i = 0;list.ForEach(p =>{taskList.Add(Task.Factory.StartNew(() =>{if (string.IsNullOrEmpty(p)) { i++; newList.Add((i).ToString() + ":" + "为空了"); return; }  //保证每个子线程都有执行 i++try{if (p == "四") throw new Exception("人造异常");#region ApiReponseBaseModel val = new ApiReponseBaseModel{Id = masterVal.Id,Success = masterVal.Success,Message = masterVal.Message};#endregionval.Message = p;Thread.Sleep(500);lock (newList){newList.Add(i.ToString() + ":" + val.Message);}}catch (Exception ex){newList.Add((i + 1).ToString() + ":" + ex.Message);}}));//taskList.Add(Task.Factory.StartNew(fn =>//{//}, null));
            });Task finalTask = Task.Factory.ContinueWhenAll(taskList.ToArray(), fn => {newList.Add("finallyTask the end");});finalTask.Wait();newList.Add("main thread the end");result.Data = newList;return result;}