并行集合--IProducerConsumerCollection<T>

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Collections;
using System.Collections.Concurrent;
using System.Threading;
namespace ConsoleApplication5
{
    class Program
    {
        static void Main(string[] args)
        {
            //****************************【ConcurrentQueue<T>】(先进先出)*************************************
            ConcurrentQueue<int> cq = new ConcurrentQueue<int>();
            for (int i = 0; i < 10; i++)
            {
                cq.Enqueue(i);//将元素添加到结尾处
            }
            int cq_result;
            cq.TryDequeue(out cq_result);//尝试移除开始处的元素，成功返回true
            cq.TryPeek(out cq_result);//访问开始处的元素，不移除
            //****************************【ConcurrentQueue<T>】（先进后出）*************************************
            ConcurrentStack<int> cs = new ConcurrentStack<int>();
            for (int i = 0; i < 10; i++)
            {
                cs.Push(i);//将元素插入到顶部
            }
            int cs_result;
            cs.TryPop(out cs_result);//弹出 并返回顶部元素
            //****************************【ConcurrentQueue<T>】*************************************
            ConcurrentBag<int> cb = new ConcurrentBag<int>();
            for (int i = 0; i < 10; i++)
            {
                cb.Add(i);//添加元素
            }
            int cb_result;
            cb.TryTake(out cb_result);//移除并返回元素
            //****************************【ConcurrentQueue<T>】*************************************
            ConcurrentDictionary<string, string> cd = new ConcurrentDictionary<string, string>();
            cd.TryAdd("a", "曹操");
            cd.TryAdd("b", "关羽");//添加键值
            string cd_result;
            cd.TryGetValue("a", out cd_result);//获取该键对应的值
            Console.WriteLine(cd.TryUpdate("a", "刘备", "曹操"));//指定键的值与第三个参数比较，相同则把第二个参数赋值给该键
            string del_result;
            cd.TryRemove("a", out del_result);//删除并返回该键对应的值

            //****************************【BlockingCollection<T>】*************************************
            BlockingCollection<int> bc = new BlockingCollection<int>(cb);
            bc.Add(1);//添加
            foreach (var item in bc)
            {
                //Console.WriteLine(item+","+bc.Take());//查看
            }

            //****************************【并行循环Parallel.For， Parallel.ForEach，Parallel.Invoke】*************************************
            //----------------------------------Parallel.For
            Parallel.For(0, 30, (r, s) =>
            {
                // 当某一个循环单元的数大于5，
                // 则跳出当前执行单元，等待其他执行单元结束
                // 所有执行单元结束后退出Parallel.For的执行
                if (r > 5)
                {
                    Console.WriteLine("a:" + r);
                    s.Break();//跳出当前单元
                }
                Console.WriteLine("b:" + r);
            });
            //----------------------------------Parallel.ForEach
            Parallel.ForEach(new int[] { 1, 2, 3, 4 }, (r, s) => {
                Console.WriteLine(r);
                s.Stop();//停止，并推出Parallel.ForEach
            });
            //----------------------------------Parallel.Invoke
            Parallel.Invoke(() => Console.WriteLine(123) ,()=>Console.WriteLine(321));//并行执行多个委托
            Console.ReadKey();
        }
    }
}