您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
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(); } } }
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。