首页 > 编程语言 >C# BlockingCollection(生产者/消费者)练习

C# BlockingCollection(生产者/消费者)练习

时间:2022-10-25 17:03:08浏览次数:49  
标签:Task C# 练习 static BlockingCollection fun Consumer

最近接手同事C#代码,(话说我一个C++程序员干嘛做这种事情,可能我是韭菜吧),为了能够承接,特地去拜读了《C#图解教程》,入门还是不错的。

写代码嘛,异步编程肯定少不了,下面就是利用C# BlockingCollection功能模块编写的 生产者/消费者 demo(韭菜要自觉生产,提供给多人消费)。

using System;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Concurrent;

namespace ConsoleApp2
{

    class Collection
    {
        public static BlockingCollection<int> bc = new BlockingCollection<int>();
    }
    class Producer
    {
        public static async Task Producer_fun()
        {
            await Task.Run(() => {
                for (int i = 0; i < 100; i++)
                {
                    Thread.Sleep(50);
                    Collection.bc.Add(i);
                    Console.WriteLine($"韭菜生产 {i}");
                }
                Collection.bc.CompleteAdding();
            });
        }
    }

    class Consumer
    {
        public static int n = 0;
        public static async Task Consumer_fun(string str)
        {
            await Task.Run(() =>
            {
                while(true){
                    Thread.Sleep(200);
                    if (Collection.bc.TryTake(out n))
                    {
                        Console.WriteLine($"{str}掠夺 {n}");
                    }
                    else
                    {
                        if (Collection.bc.IsCompleted)
                            break;
                    }
                }

            });
        }
    }

    class Program
    {
        static void Main(string[] args)
        {
            Task t1 = Producer.Producer_fun();
            Task t2 = Consumer.Consumer_fun("JD");
            Task t3 = Consumer.Consumer_fun("ali");
            Task t4 = Consumer.Consumer_fun("QQ");
            Task t5 = Consumer.Consumer_fun("apple");
            Task.WaitAll(t1, t2, t3,t4,t5);

        }
    }
}

 

相对于C++来说,C#的BlockingCollection(生产/消费)使用真的非常方便,还线程安全。。。。

标签:Task,C#,练习,static,BlockingCollection,fun,Consumer
From: https://www.cnblogs.com/GEEK-ZHAO/p/16825451.html

相关文章

  • (C++) 类与 static_cast 与 dynamic_cast
    static_caststatic_cast相当于C语言里面的强制转换,适用于:用于类层次结构中基类(父类)和派生类(子类)之间指针或引用的转换。进行上行转换(把派生类的指针或引用转换成基类表......
  • CF 767C Garland
    题目链接:​​传送门​​​题面:个节点的树第个节点权值为问是否能够删除掉两条边,使得该树分成三个不为空,并且每部分权值之和相等.无解输出否则输出要删除边()的节点序号S......
  • HDU 2844 Coins
    题目链接:​​传送门​​​题面:ProblemDescriptionWhuacmersusecoins.TheyhavecoinsofvalueA1,A2,A3…AnSilverlanddollar.OnedayHibixopenedpurseandfoun......
  • 测试人员参加项目POC的核心价值
    (一)参加项目POC要了解的内容客户的数据应用于哪些业务场景客户目前面临的挑战通过POC,希望达成什么目标客户有调研过哪些竞品,未选择的原因是什么产品在客户环境的使用......
  • HDU 2602 Bone Collector
    题目链接:​​传送门​​​题面:ProblemDescriptionManyyearsago,inTeddy’shometowntherewasamanwhowascalled“BoneCollector”.Thismanliketocollec......
  • SpringBoot2配置HikariCP连接池的密码保护
    本文讨论如何保护SpringBoot配置文件中的数据库连接信息,一般情况下application.properties里会如下配置DataSource:spring.datasource.driver-class-name=com.mysql.cj.jdbc.......
  • IPW65R110CFDA英飞凌车规MOS管\原装现货ASEMI代理
    编辑:llIPW65R110CFDA英飞凌车规MOS管\原装现货ASEMI代理型号:IPW65R110CFDA品牌:ASEMI封装:TO-247最大漏源电流:99.6A漏源击穿电压:650VRDS(ON)Max:0.099Ω引脚数量:3特性:车规级MOS管......
  • Centos环境下docker 安装 (一)
    1.安装之前先排查下是否有残留的docker安装包,如果有先删除。$ sudo yumremove docker\         docker-client\         d......
  • Spring MVC的执行流程
    SpringMVC的执行流程如下:用户点击某个请求路径,发起一个HTTPrequest请求,该请求会被提交到 DispatcherServlet(前端控制器);由DispatcherServlet 请求一个或多个Han......
  • script python and python interpreter
    sPython和Python解释器https://www.cnblogs.com/nickchen121/p/10722729.html目录一、Python介绍二、Python解释器发展史三、Python解释器的类型3.1CPython3.2......