tpl-dataflow Questions
2
Solved
The scheduling of async Tasks does not work as I expected in TPL Dataflow. In the example below, I expected the ActionBlock to process data from the TransformBlock as soon as it is available. But i...
Numeral asked 27/11, 2014 at 12:32
1
Solved
There are 2 different official TPL Dataflow nuget package. I am confused to choose which one i should to use.
As far as i understand System.Threading.Tasks.Dataflow version is tiny bit newer than...
Hyacinthie asked 9/9, 2016 at 13:21
2
Solved
I have producer / consumer pattern in my app implemented used TPL Dataflow. I have the big dataflow mesh with about 40 blocks in it. There are two main functional parts in the mesh: producer part a...
Chophouse asked 13/8, 2016 at 17:13
3
Solved
This is short code sample to quickly introduce you what is my question about:
using System;
using System.Linq;
using System.Threading.Tasks;
using System.Threading.Tasks.Dataflow;
namespace Dataf...
Victim asked 9/8, 2016 at 10:7
1
I've written a small pipeline using the TPL Dataflow API which receives data from multiple threads and performs handling on them.
Setup 1
When I configure it to use MaxDegreeOfParallelism = Envi...
Fallal asked 15/6, 2016 at 11:8
2
The full exception text is:
EventSourceException: No Free Buffers available from the operating
system (e.g. event rate too fast).
I am calling this method approx a million times because of re...
Roundtheclock asked 23/7, 2015 at 7:47
2
Solved
I would like to know what is the recommended way to execute multiple async methods in parallel?
in System.Threading.Tasks.Dataflow we can specify the max degree of parallelism but unbounded is pro...
Mccullough asked 16/5, 2016 at 8:34
1
After days of googleing I think I can't decide which one is for what scenario. Of course I would like to use a perfect framework which combines both (unrealistic of course). I even know that it's p...
Amidst asked 18/1, 2013 at 16:17
1
When you create a batchblock with bounded capacity and call triggerBatch while (In parallel to) posting a new item - posting new item will fail during the trigger batch execution time.
Calling Tri...
Drub asked 25/2, 2016 at 12:12
3
I am trying to implement a data processing pipeline using TPL Dataflow. However, I am relatively new to dataflow and not completely sure how to use it properly for the problem I am trying to solve....
Scheers asked 12/2, 2016 at 20:48
1
Solved
I'm new to C# TPL and DataFlow and I'm struggling to work out how to implement the TPL DataFlow TransformManyBlock. I'm translating some other code into DataFlow. My (simplified) original code was ...
Jerboa asked 9/11, 2015 at 12:2
2
Solved
While working on an answer to this question, I wrote this snippet:
var buffer = new BufferBlock<object>();
var producer = Task.Run(async () =>
{
while (true)
{
await Task.Delay(TimeSpa...
Hokanson asked 16/8, 2014 at 9:58
2
Solved
Given:
A list of ids of emails
What I'm doing:
With the BatchBlock group ids and call a Transformblock for each block the simplified transformblock looks like this:
var readBatch = new Transfor...
Afc asked 6/9, 2015 at 9:29
1
Solved
I wrote the following method to batch process a huge CSV file. The idea is to read a chunk of lines from the file into memory, then partition these chunk of lines into batches of fixed size. Once w...
Viperous asked 16/8, 2015 at 4:19
1
I am designing a long-running Dataflow pipeline that consists of multiple blocks. Items are fed to the input block of the pipeline, eventually make their way through it, and are displayed in the UI...
Coycoyle asked 12/8, 2015 at 5:13
2
Solved
I'm processing images using TPL Dataflow. I receive a processing request, read an image from a stream, apply several transformations, then write the resulting image to another stream:
Request ->...
Vie asked 30/1, 2013 at 19:51
1
Solved
I'm trying to use a bounded batchblock linked to an action block.
I know when the feeding of items in the batchblock end and I want to trigger a completion chain.
The problem is: if my BatchBlock...
Bog asked 16/7, 2015 at 9:45
1
Solved
I am building a Dataflows pipeline whose job it is to process large files. Each file is parsed, analyzed, and rendered; but every file may take a different path through the pipeline, depending on w...
Propagandism asked 10/7, 2015 at 18:59
2
Solved
I am looking for a TPL data flow block solution which can hold more than a single item, which can link to multiple target blocks, but which has the ability to forward an item to only a specific tar...
Nkrumah asked 28/11, 2012 at 6:35
2
Solved
I want to limit the number of items posted in a Dataflow pipeline. The number of items depends of the production environment.
These objects consume a large amount of memory (images) so I would like...
Batholomew asked 3/3, 2015 at 17:17
2
Solved
Im brand new to TPL dataflow so forgive me if this is a simple question.
I have an input buffer block that takes a base class. How can I branch from there to a block based on the derived type? So ...
Tiphanie asked 2/9, 2014 at 14:46
1
Solved
Does the BoundedCapacity limit only includes items in the input queue waiting to be processed or does it also count items being processed at the moment?
Lets take for example this ActionBlock:
va...
Reedbuck asked 27/10, 2014 at 18:43
1
Solved
I have this code:
var data = new BufferBlock<int>(new DataflowBlockOptions { BoundedCapacity = 1 });
var action = new ActionBlock<int>(async id =>
{
Console.WriteLine("[{0:T}] #{1...
Bailiwick asked 26/10, 2014 at 19:34
1
Solved
I have a BatchBlock with BoundedCapacity defined on it
var _batchBlock = new BatchBlock<int>(2, new GroupingDataflowBlockOptions
{BoundedCapacity = 100 });
So if the queue capacity reache...
Kolkhoz asked 16/10, 2014 at 1:6
1
I am attempting to use TPL Dataflow to create a pipeline. All is working fine so far, with my pipeline defined as follows (although my issue is just with broadcaster, submissionSucceeded, submissio...
Durst asked 3/2, 2014 at 17:47
© 2022 - 2024 — McMap. All rights reserved.