并行集合--IProducerConsumerCollection<T>

发布时间:2020-09-09 07:44:26 作者:1473348968
来源:网络 阅读:1351
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();
        }
    }
}

推荐阅读:
  1. Oracle并行基础一
  2. C#并行和合买平台搭建并行集合和PLinq

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

集合 并行 ce

上一篇:nginx反向代理之多端口映射的实现

下一篇:python通过opencv实现图片裁剪原理解析

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》