在.NET Core中使用Channel（三）
码农驿站 2021/1/11 16:07:36 次
到目前为止，我们一直在使用所谓的“Unbounded”通道。你会注意到，当我们创建通道时，我们这样做:
var myChannel = Channel.CreateUnbounded<int>();
但实际上，我们可以这样做：
var myChannel = Channel.CreateBounded<int>(1000);
这与创建容量有限的列表或数组等其他集合类型并无太大差别。在我们的示例中，我们创建了一个最多容纳1000项的Channel。但为什么要限制自己呢?这就是背压的作用。
什么是背压?
背压(特别是当涉及消息传递/排队时)是指资源(无论是内存、ram、网络)是有限的。我们应该能够在链条上施加“压力”，试着减轻一些压力。至少，让生态系统中的其他人知道我们负荷过重，我们可能需要一些时间来处理他们的请求。
一般来说，当我们讨论队列的背压时。几乎所有情况下，我们都在讨论一种方法，告诉任何试图在队列中添加更多条目的人，要么他们根本无法再加入任何条目，要么他们需要推后一段时间。更罕见的是，我们讨论的队列是在达到一定容量时纯粹丢弃消息。这种情况很少发生，但是我们有这个选项。
那么它是如何与.net Channel一起工作的呢?
Channel中的背压
当使用通道时，我们实际上有一个非常简单的方法来增加背压。代码看起来是这样的:
var channelOptions = new BoundedChannelOptions(5)
{
FullMode = BoundedChannelFullMode.Wait
};
var myChannel = Channel.CreateBounded<int>(channelOptions);我们可以指定以下完整模式:
等待
在打开WriteAsync()调用之前，只需让调用者等待。
DropNewest / DropOldest
可以在Channel中拖放最老的或最新的项目，为我们想要添加的项腾出空间。
DropWrite
简单地转储我们应该写的消息。
还有另外两段代码需要注意。
你可以调用WaitToWriteAsync():
await myChannel.Writer.WaitToWriteAsync();
这让我们Channel成了有界。当Channel已满时，我们可以简单地等待，直到有空间。这意味着，即使打开了DropWrite FullMode，我们也可以通过简单地等待，直到有容量为止，来限制扔在地面上的消息数量。
我们应该注意的另一段代码是:
var success = myChannel.Writer.TryWrite(i);
这允许我们尝试写入队列，并返回，无论成功与否。需要注意的是，此方法不是异步的。要么写入信道要么不写入信道，这里没有"如果你再多等一会儿，也许可以。”
欢迎关注我的公众号，如果你有喜欢的外文技术文章，可以通过公众号留言推荐给我。
关于找一找教程网
本站文章仅代表作者观点，不代表本站立场，所有文章非营利性免费分享。
本站提供了软件编程、网站开发技术、服务器运维、人工智能等等IT技术文章，希望广大程序员努力学习，让我们用科技改变世界。
[在.NET Core中使用Channel（三）]http://www.zyiz.net/tech/detail-150821.html
您可能感兴趣的文章:
- 2020-02-22.netcore 3.1高性能微服务架构：加入swagger接口文档
- 2019-09-04迭代器模式随想
- 2019-09-04C#开发BIMFACE系列12 服务端API之文件转换
- 2019-09-04.NET Core 学习资料精选：进阶
- 2019-09-04.Net cache与cache更新
- 2019-09-04ASP.NET Core 2.1 : 十二.内置日志、使用Nlog将日志输出到文件
- 2019-09-04ASP.NET Core 2.2 : 十六.扒一扒新的Endpoint路由方案
- 2021-01-19spring-cloud 使用初谈（二）--网关
- 2021-01-19改进你的c#代码的5个技巧（四）
- 2021-01-18反射
扫描二维码或查找【程序员编程王】
可以随时随地学编程啦！
共有 条评论 网友评论