大师网-带你快速走向大师之路 解决你在学习过程中的疑惑,带你快速进入大师之门。节省时间,提升效率

.NetCore利用BlockingCollection实现简易消息队列

public DemoQueueBlock() { } public static bool IsComleted() { if (Colls ! } public static bool HasEle() { if (Colls ! } Colls.Add(msg); } public static T Take() { if (Colls == null) { Colls = new BlockingCollection (); } return Colls.Take();Add(new DemoMessage() { BusinessId = read }); Console.WriteLine("已消费:" + m.BusinessId); 查看运行结果 运行结果 这样我们就实现了简易的消息队列。 示例源码 简易队列 参考链接 BlockingCollectionOrleans源码分析