使用TPL ActionBlock，我可以在作业完成后添加新项目吗？
TPL ActionBlock是.NET Framework中的一个类，用于实现数据流编程模型。它允许我们以异步的方式处理数据流，并且可以在作业完成后添加新项目。
ActionBlock是TPL中的一个数据流块，它接收输入数据并执行指定的操作。当我们向ActionBlock发送一个项目时，它会执行我们定义的操作，并且可以返回一个结果。在作业完成后，我们可以继续向ActionBlock发送新的项目。
使用TPL ActionBlock的主要优势是它提供了一种简单而强大的方式来处理异步任务。它可以帮助我们实现并行处理、异步处理和流水线处理等场景。同时，它还提供了一些高级功能，如数据流块链接、取消操作和错误处理等。
在云计算领域，我们可以利用TPL ActionBlock来处理一些并行计算任务，如数据处理、图像处理、视频处理等。它可以帮助我们提高计算效率，加快处理速度，并且可以方便地与其他云计算服务进行集成。
腾讯云提供了一些与TPL ActionBlock类似的服务和产品，如云函数（SCF）和消息队列（CMQ）。云函数是一种无服务器计算服务，可以帮助我们以事件驱动的方式执行代码。消息队列是一种可靠的消息传递服务，可以帮助我们实现异步消息处理。这些产品都可以与TPL ActionBlock结合使用，以实现更复杂的计算任务。
关于TPL ActionBlock的更多信息，您可以参考腾讯云的官方文档：
相关·内容
我在我的应用程序中使用了第三方ActionBlock来实现并行性。
我有一个应用程序，它将根据用户输入执行操作。根据输入，动作有时需要更多时间，有时则不需要。因此，ActionBlock的真正用途是，每当输入到来时，我希望首先在UI中显示它(有一个窗口)，然后在后台执行操作。因此，这个想法就像来自用户的任何东西，在UI中显示出来，并在后台并行执行。现在，在UI(窗口)中，我有一个停止按钮来停止用户输
浏览 4提问于2020-05-19得票数 0
2回答
我有一个与设备一起工作的类，以避免使用设备和串口时UI层中的延迟，但是我的设备一次只能做一个工作。因此，我有一个队列，当用户要求执行添加到其中的任务时，我会运行一个线程逐个执行任务。每次用户请求任务时，我都会检查线程是否正在运行，如果是的话，我只是向队列中添加新任务，如果不是，则再次创建线程。这意味着每次队列空时，我都应该创建一个新线程。现在我想问一下，有什么方法可以重用线程吗？既
浏览 7提问于2014-09-28得票数 3
回答已采纳
1回答
我之所以开始研究这个问题，是因为我想要实现这样一个场景:可以运行并行任务，但是按照顺序，并发现TPL可以这样使用。我正在实践TPL和TPL数据流，并且处于非常初级的水平，所以我需要专家的帮助，他们可以引导我走向正确的方向。在我写的测试方法中，我做了以下事情，
private void btnTPLDataFlow_Click(object sen
浏览 6提问于2015-08-18得票数 3
2回答
如何使用线程处理许多任务
、、、
我有一个C#要求单独处理“很多”(也许是100,000条)记录.按部就班地运行这个过程被证明是非常缓慢的，每条记录都需要很好的秒才能完成(超时错误设置为5秒)。我想尝试通过使用一定数量的工作“线程”来异步运行这些任务(我在这里谨慎地使用“线程”这个术语，因为我不确定是否应该查看线程、任务或其他东西)。我看过ThreadPool，但我无法想象它能够对所需的请求数量进行排队。var task = WaitForNextAvailableThreadFromPool(Proc
浏览 2提问于2015-01-08得票数 6
回答已采纳
1回答
我目前正在使用ActionBlock来处理串行启动的异步作业。它可以很好地处理发送给它的每个项目，但是没有办法收集每个作业的结果列表。var actionBlock = new ActionBlock<int> (async i => await Process(i));{
ac
浏览 0提问于2018-03-20得票数 2
回答已采纳
实际上，我在TPL数据流方面遇到了一个问题(似乎一个项目被添加了两次)。因此，我想知道，如果将一个项提交到目标块，是否可以插入回调(可以用于日志记录)。我检查了ActionBlock、BufferBlock构造函数以及LinkTo方法，但没有找到任何东西。
有什么暗示吗？
浏览 3提问于2017-11-08得票数 2
回答已采纳
考虑下面的程序，它使用TPL数据流。因此，ActionBlock来自Dataflow库。只在完成上一个异步任务时才开始处理下一个任务。我如何才能强迫它开始处理下一个任务，即使前一个任务还没有完全完成。MaxDegreeOfParallelism不是一种选择，因为这会扰乱订单。Started with 2Started with 4Done with 1Done with 3我<e
浏览 27提问于2022-09-07得票数 0
1回答
使用异步操作的TPL数据流
、、、、
我正在尝试使用TPL数据流，通过移植一些旧的套接字代码来使用TPL数据流和新的异步特性。虽然API感觉很坚固，但我的代码最终还是会感到混乱。我在想我是不是漏掉了什么。我的要求如下:套接字类公开:打开、关闭、发送和接收方法。它们都返回一个任务，因此都是异步的。打开和关闭都是原子的。发送和接收可以相邻工作，虽然每次只能处理一个命令。在此期间，我可以安全地将操作发送到发送和接收块，而不必担心正在运行的连接相关操作。此外，<
浏览 3提问于2012-06-12得票数 4
回答已采纳
2回答
我不确定以下操作是否可行，但我希望以有节流的方式并行调用一些操作，但要保持处理流程的连续性，而不是返回到使用计时器或循环/睡眠周期。到目前为止，我已经让它工作了，它从某些来源加载了大量的输入……然后以受控的方式并行处理它们&像下面这样循环。input); Console.WriteLine("Finishing Task {0}", input);我想知道的是，在T
浏览 0提问于2012-02-11得票数 5
回答已采纳
我的应用程序使用RTSPClientSharp库从摄像机中流，当解码帧准备就绪时，会引发一个OnFramesReceived事件。在同一事件中，我将解码的帧转换为位图，这是一个阻塞调用，占用超过100 is，导致帧速率减慢到10 FPS。为了解决这个问题，我使用了来自的Task代码，它使用Task.ContinueWith.UnWrap将ProcessFrame事件排队(具有将解码帧转换为位图的代码)。我的目标是按照接收帧的顺序顺序执行ProcessF
浏览 10提问于2020-08-26得票数 0
1回答
我有一个需要并行处理的特定项目的源源不断的流，所以我使用TPL Dataflow。问题是，共享相同密钥的项(类似字典)应该按照FIFO顺序进行处理，而不是彼此并行(它们可以与具有不同值的其他项并行)。所做的工作是用最小的异步锁绑定CPU，所以我的解决方案是创建一个ActionBlock<T>数组，其大小为Environment.ProcessorCount，没有并行性，并根据键的GetHashCode];
浏览 3提问于2014-01-09得票数 6
回答已采纳
1回答
同时测试代理列表的有效性
、、、
我有一个类，它同时测试代理列表的有效性，我用两种不同的方式创建了它，一种是利用Parallel.ForEach，另一种是使用TPL数据流ActionBlock。我只是想知道哪一个是首选的，如果我忽略了一些重要的事情。另外，我创建了Dataflow版本，因为我希望能够对代理测试进行排队，使用Parallel.ForEach版本我可能可以做到这一点，但这需要更多的代码和一些重构。
我仍
浏览 0提问于2018-05-07得票数 11
我想使用BackgroundService并行处理一些数据。例如，如果数据库中有20个项要处理，并且MaxDegreesOfParallelism (允许并发处理作业的数量)为10，我只想加载10个项。几分钟后，前3项可能会被处理。此时，我想从数据库加载接下来的3项。当然，当程序启动时，我可以加载所有20个项目，但当“处理时隙”在几分钟后可用时，这20个项可能不再反映数据库的当前状态。它不必是立即的，如果“数据加载”服务/线程每分钟检查一次是
浏览 1提问于2022-09-22得票数 0
回答已采纳
3回答
我在遵循MVVM模式的WPF应用程序中使用TPL数据流。我有一个TransformBlock<object,object>和一个ActionBlock<object>，我把它们链接起来如下：我就是这样实例化TPL的：{
浏览 0提问于2014-04-09得票数 5
回答已采纳
在C# TPL数据流库中，SingleProducerConstrained是ActionBlocks的一个优化选项，您可以在只有一个线程提供操作块的情况下使用它：
如果一个块一次只能由单个生成器使用，这意味着一次只使用一个线程，例如在块上使用Post、OfferMessage和Complete等方法，则可以将该属性设置为true，以通知该块不需要应用额外的同步。如果一个ActionBlock是使用</em
浏览 2提问于2014-03-18得票数 11
回答已采纳
3回答
我有ETL项目，其中有一些处理组件。单个组件是基于BlockingCollection的生产者-消费者。如果不设置进程的处理器关联(这似乎有点过分)，是否有可能强迫任务在单个内核上运行(我不希望它们占用100%的多核CPU)？
请注意，我仍然希望任务以并行的方式运行--就在一个核心上。
浏览 2提问于2016-01-19得票数 3
回答已采纳
我有一个SKScene，在这里我要添加一个SKSpriteNode。我已经子类SKSpriteNode类来创建这个节点。在子类中，我在sprite上定义了某些SKActions。我想要的是，当运行在这个sprite上的SKAction序列结束时，我在场景中添加一个新的sprite节点。这怎么可能。以下是我的代码：
我在skspritenode子类(TEMissil
浏览 3提问于2014-07-25得票数 1
回答已采纳
在我的例子中，我想取消整个dataFlow，以防在一个计算步骤中出现异常。谢谢..。editAs Ofir提到，我可以： {;)
接下来我可
浏览 3提问于2017-03-09得票数 3
1回答
我有一个TPL数据流，它可以很好地使用转换块，然后是动作块。我添加了一个新的操作块，它将与现有的操作块同时执行，但是我的新操作块永远不会被击中。没有引发错误或异常。我需要在代码中添加一个步骤吗？ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 4 }
var uploadInS3Block = new ActionBloc
浏览 7提问于2022-01-25得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
