Parallel.For(0, 1000, (i) =>{//i是从0开始一直到1000结束
});var lst = new List<string>();Parallel.ForEach(lst, (s) =>{//do something
            });//Invoke
            Parallel.Invoke(() => { },() => { },() => { }); 

           Parallel.ForEach(new List<string>{"aa","bb","cc","dd","ee",}, (b) =>{Thread.Sleep(1000);throw new Exception(b);});}catch (AggregateException ex){foreach (var exception in ex.Flatten().InnerExceptions){Console.WriteLine(exception.Message);}}

    public class ParallelOptions{public ParallelOptions();//允许取消操作public CancellationToken CancellationToken { get; set; }//允许指定可以并发操作的最大工作项目数public int MaxDegreeOfParallelism { get; set; }//允许指定要使用哪个TaskSchedulerpublic TaskScheduler TaskScheduler { get; set; }}

　　　　　　  //定义线程取消的一个对象var cancel = new CancellationTokenSource();var po = new ParallelOptions() { CancellationToken = cancel.Token, MaxDegreeOfParallelism = 2, }; //为了不堵塞线程,这里开启一个线程 Task.Run(() => { try { Parallel.For(0, 1000, po, (i) => { Thread.Sleep(1000); po.CancellationToken.ThrowIfCancellationRequested(); Console.WriteLine(i); }); } catch (AggregateException ex) { foreach (var e in ex.Flatten().InnerExceptions) { Console.WriteLine(e.Message); } } catch (Exception ex) { //OperationCanceledException  Console.WriteLine(ex.GetType().Name); } //不设置取消的TOKEN  }, CancellationToken.None); Thread.Sleep(10 * 1000); cancel.Cancel();

public static ParallelLoopResult For<TLocal>　　(int fromInclusive, int toExclusive, 　　  Func<TLocal> localInit, 　　  Func<int, ParallelLoopState, TLocal, TLocal> body,      Action<TLocal> localFinally);

public static void Parallel_For_Local_Test(){ int[] nums = Enumerable.Range(0, 1000000).ToArray<int>();long total = 0;ParallelLoopResult result = Parallel.For<long>(0, nums.Length,() => { return 0; },(j, loop, subtotal) =>{// 延长任务时间，更方便观察下面得出的结论
Thread.SpinWait(200);Console.WriteLine("当前线程ID为：{0},j为{1}，subtotal为：{2}。", Thread.CurrentThread.ManagedThreadId, j.ToString(), subtotal.ToString());if (j == 23)loop.Break();if (j > loop.LowestBreakIteration){Thread.Sleep(4000);Console.WriteLine("j为{0},等待4s种，用于判断已开启且大于阻断迭代是否会运行完。", j.ToString());}Console.WriteLine("j为{0},LowestBreakIteration为：{1}", j.ToString(), loop.LowestBreakIteration);subtotal += nums[j];return subtotal;},(finalResult) => Interlocked.Add(ref total, finalResult));Console.WriteLine("total值为：{0}", total.ToString());if (result.IsCompleted)Console.WriteLine("循环执行完毕");elseConsole.WriteLine("{0}", result.LowestBreakIteration.HasValue ? "调用了Break()阻断循环." : "调用了Stop()终止循环.");}

public class ParallelLoopState{// 获取循环的任何迭代是否已引发相应迭代未处理的异常。public bool IsExceptional { get; }// 获取循环的任何迭代是否已调用 ParallelLoopState.Stop()。public bool IsStopped { get; }// 获取在Parallel循环中调用 ParallelLoopState.Break() 的最低循环迭代。public long? LowestBreakIteration { get; }// 获取循环的当前迭代是否应基于此迭代或其他迭代发出的请求退出。public bool ShouldExitCurrentIteration { get; }//通知Parallel循环当前迭代”之后”的其他迭代不需要运行。public void Break();//通知Parallel循环当前迭代“之外”的所有其他迭代不需要运行。public void Stop();
}