本文共 3526 字，大约阅读时间需要 11 分钟。
代码：
#region Task 异步多线程，Task是基于ThreadPool实现的 { //TestClass testClass = new TestClass(); //Action action = new Action(t => testClass.TestThread(t.ToString())); //TaskFactory taskFactory = new TaskFactory(); //List taskList = new List (); //for (int i = 0; i < 5; i++) //{ // Task task = taskFactory.StartNew(action, "task" + i); // taskList.Add(task); //} //同步等待 ////1.1所在线程等待，目前在主线程，等待某一个Task执行完毕，只要有一个完成，就继续往下执行。会卡住主线程。 //Task.WaitAny(taskList.ToArray()); //Console.WriteLine("某一个Task执行完毕"); ////1.2所在线程等待，目前在主线程，直到所有Task执行完毕；会卡住主线程。 //Task.WaitAll(taskList.ToArray()); //Console.WriteLine("所有Task执行完毕"); ////2.1回调等待 ////不卡主线程，所有Task完成，才执行下面的操作 //taskFactory.ContinueWhenAll(taskList.ToArray(), taskArray => //{ // Console.WriteLine("taskFactory.ContinueWhenAll {0}", Thread.CurrentThread.ManagedThreadId); // foreach (var item in taskArray) // { // Console.WriteLine(item.AsyncState); // Console.WriteLine(item.IsCompleted); // } //}); ////2.2回调等待 ////不卡主线程，有一个Task完成，就执行下面的操作 //taskFactory.ContinueWhenAny(taskList.ToArray(), taskAction => //{ // Console.WriteLine("taskFactory.ContinueWhenAny {0}", Thread.CurrentThread.ManagedThreadId); // Console.WriteLine(taskAction.AsyncState); // Console.WriteLine(taskAction.IsCompleted); //}); } #endregion #region Parallel 基于Task实现，多个任务并行计算，主线程也会计算，其实就是Task+WaitAll，一定会卡住主线程 { //Console.WriteLine("主线程的ID：{0}", Thread.CurrentThread.ManagedThreadId); //Parallel.Invoke(() => { Console.WriteLine("当前线程的ID：{0}", Thread.CurrentThread.ManagedThreadId); }, // () => { Console.WriteLine("当前线程的ID：{0}", Thread.CurrentThread.ManagedThreadId); }, // () => { Console.WriteLine("当前线程的ID：{0}", Thread.CurrentThread.ManagedThreadId); }, // () => { Console.WriteLine("当前线程的ID：{0}", Thread.CurrentThread.ManagedThreadId); }, // () => { Console.WriteLine("当前线程的ID：{0}", Thread.CurrentThread.ManagedThreadId); }); ////全部完成后，进入下一步，看上去就像同步编程 //Parallel.ForEach (new int[] { 1, 2, 3, 4, 5 }, t => //{ // Console.WriteLine("当前线程ID：{0}，结果：{1}", Thread.CurrentThread.ManagedThreadId, t * t); // Thread.Sleep(100); //}); // ParallelOptions options = new ParallelOptions() { MaxDegreeOfParallelism = 5 }; Parallel.For(0, 1000, options, t => { Console.WriteLine("结果：" + t.ToString()); }); Parallel.For(0, 1000, options, (t, state) => { Console.WriteLine("结果：" + t.ToString()); //state.Break();// //state.Stop();// //return; }); } #endregion
转载于:https://www.cnblogs.com/xsj1989/p/7833682.html