我的场景是，我有一个BufferBlock<Stream>接收来自外部来源的Stream，比方说文件系统或某个FTP服务器。这些文件Stream将传递到另一个块并进行处理。 唯一的问题是这些文件中的一部分是压缩的，我想在中间添加一个Block，它将在必要时解压缩文件，并为其每个条目创建多个输出Stream。 但是我不想使用TransformBlockMany，因为这意味着我必须完全收到ZIP St
我有大量需要执行的任务（〜1000）。我使用的是四核处理器，所以我想同时处理4个任务。 为了给你一个出发点，下面是一些示例代码。 class Program
{
public class LongOperation
{
private static readonly Random RandomNumberGenerator = new Random(0);
TPL数据流库我的应用程序非常有用的。我有大约10块，我认为计数会增加。 当我准备我的应用程序的原型时，我很困惑，因为我明白我得到了功能设计。 void BIG_WORKFLOW_METHOD()
{
...
var block1 = new TransformBlock<string, string>(...);
var block2 = new Transfor
我需要实现可以从多个线程填充请求的队列。当这个队列变得大于1000个完成的请求时，这个请求应该被存储到数据库中。这是我的实现： public class RequestQueue
{
private static BlockingCollection<VerificationRequest> _queue = new BlockingCollection<VerificationReq
我一直在寻找的.NET TPL的“数据流”库的某些部分出于好奇的执行情况和我遇到下面的代码片段来了： private void GetHeadTailPositions(out Segment head, out Segment tail,
out int headLow, out int tailHigh)
{
head = _head;
tail