Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Create benchmarks for System.Threading.Tasks.Dataflow #951

Open
wants to merge 18 commits into
base: main
Choose a base branch
from
Open

Create benchmarks for System.Threading.Tasks.Dataflow #951

Changes from 1 commit
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
aaca250
Create BufferBlock Dataflow perf tests
manandre Oct 16, 2019
c529438
Add ActionBlock Dataflow perf tests
manandre Oct 16, 2019
c5a4d94
Add Parallel and Unordered ActionBlock perf tests
manandre Oct 16, 2019
9c1b400
Add TransformBlock Dataflow perf tests
manandre Oct 16, 2019
d1a5180
Add BroadcastBlock Dataflow perf tests
manandre Oct 17, 2019
c8a7c09
Add Batch & Join Dataflow perf tests
manandre Oct 17, 2019
432afcf
Add Reactive Dataflow perf tests
manandre Oct 17, 2019
36c8cd5
Refactor Dataflow perf tests
manandre Oct 17, 2019
a12eb17
Fix BroadcastBlock benchmark hang up
manandre Oct 18, 2019
bc69b86
Use full name instead of the SPC abbreviation
manandre Oct 19, 2019
11eb153
Reduce the inheritance hierarchy depth
manandre Oct 19, 2019
8ee7a19
Intoduce the classes in order they are referenced
manandre Oct 19, 2019
9b92331
Devide the #regions into separate C# files
manandre Oct 19, 2019
e43520b
Add TryReceive perf tests and refactor
manandre Oct 27, 2019
93640b3
Add Batched/JoinBlock3 perf tests
manandre Oct 29, 2019
f6e97aa
Update according to first review
manandre Nov 6, 2019
d18d87a
Create a new block when complete must be called
manandre Nov 7, 2019
5df8fbb
Update according to second review
manandre Nov 9, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fix BroadcastBlock benchmark hang up 
Refactoring is not always your friend...
  • Loading branch information
@manandre
manandre committed Oct 18, 2019
commit a12eb1707f0ee1baa8ff698516cda4f00b863960
14 changes: 7 additions & 7 deletions src/benchmarks/micro/corefx/System.Threading.Tasks.Dataflow/Perf.Dataflow.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -163,20 +163,20 @@ public override IPropagatorBlock<int, int> CreateBlock() =>
});

[Benchmark(OperationsPerInvoke = 100_000)]
public Task PostMultiReceiveParallel() => MultiParallel(Post());
public Task PostMultiReceiveParallel() => MultiParallel(() => Post());

[Benchmark(OperationsPerInvoke = 100_000)]
public Task SendMultiReceiveAsyncParallel() => MultiParallel(SendAsync());
public Task SendMultiReceiveAsyncParallel() => MultiParallel(() => SendAsync());

private async Task MultiParallel(Task task)
private async Task MultiParallel(Func<Task> doTask)
{
var options = new DataflowLinkOptions { PropagateCompletion = true };
var action1 = new ActionBlock<int>(i => { });
var action2 = new ActionBlock<int>(i => { });
block.LinkTo(action1, options);
block.LinkTo(action2, options);

await task;
await doTask();
block.Complete();

await Task.WhenAll(action1.Completion, action2.Completion);
Expand Down Expand Up @@ -271,11 +271,11 @@ public async Task Completion()
await block.Completion;
manandre marked this conversation as resolved.
Show resolved Hide resolved
}

protected static Task Post(ITargetBlock<int> target) => Task.Run(() =>
protected static Task Post(ITargetBlock<int> target, bool retry = false) => Task.Run(() =>
{
for (int i = 0; i < 100_000; i++)
{
while (!target.Post(i)) ;
while (!target.Post(i) && retry) ;
}
});

Expand Down Expand Up @@ -371,7 +371,7 @@ public abstract class BoundedPropagatorPerfTests<T, U> : PerfTests<T> where T :
[Benchmark(OperationsPerInvoke = 100_000)]
public async Task PostReceiveParallel()
{
await Task.WhenAll(Post(block), Receive(block));
await Task.WhenAll(Post(block, retry: true), Receive(block));
}

[Benchmark(OperationsPerInvoke = 100_000)]
Expand Down