mattwarren · June 28, 2016 10:47 · mattwarren · Jun 28, 2016 · mattwarren · Jun 28, 2016
diff --git a/ContinueWithAllocations.cs b/ContinueWithAllocations.cs
    [Config(typeof(Config))]
    public class ContinueWithAllocations
    {
        private class Config : ManualConfig
        {
            public Config()
            {
                Add(new MemoryDiagnoser());
            }
        }

        [Params(100, 200, 500)]
        public int NumberOfTasks { get; set; }

        private ConcurrentDictionary<Task, Task> tasks;

        [Setup]
        public void SetUp()
        {
            tasks = new ConcurrentDictionary<Task, Task>();
        }

        [Benchmark]
        public Task ContinueWithClojureCapture()
        {
            for (int i = 0; i < NumberOfTasks; i++)
            {
                var runningTask = Task.Delay(1);
                tasks.TryAdd(runningTask, runningTask);
 #pragma warning disable CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
                runningTask.ContinueWith(t =>
                {
                    Task toBeRemoved;
                    tasks.TryRemove(t, out toBeRemoved);
                }, TaskContinuationOptions.ExecuteSynchronously);
 #pragma warning restore CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
            }

            return Task.WhenAll(tasks.Values);
        }

        [Benchmark]
        public Task ContinueWithWithoutClojureCapture()
        {
            for (int i = 0; i < NumberOfTasks; i++)
            {
                var runningTask = Task.Delay(1);
                tasks.TryAdd(runningTask, runningTask);
 #pragma warning disable CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
                runningTask.ContinueWith((t, state) =>
                {
                    var runningTasks = (ConcurrentDictionary<Task, Task>) state;
                    Task toBeRemoved;
                    runningTasks.TryRemove(t, out toBeRemoved);
                }, tasks, TaskContinuationOptions.ExecuteSynchronously);
 #pragma warning restore CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
            }

            return Task.WhenAll(tasks.Values);
        }
    }
diff --git a/Results.Home.md b/Results.Home.md
	[Config(typeof(Config))]
	public class ContinueWithAllocations
	{
	private class Config : ManualConfig
	{
	public Config()
	{
	Add(new MemoryDiagnoser());
	}
	}

	[Params(100, 200, 500)]
	public int NumberOfTasks { get; set; }

	private ConcurrentDictionary<Task, Task> tasks;

	[Setup]
	public void SetUp()
	{
	tasks = new ConcurrentDictionary<Task, Task>();
	}

	[Benchmark]
	public Task ContinueWithClojureCapture()
	{
	for (int i = 0; i < NumberOfTasks; i++)
	{
	var runningTask = Task.Delay(1);
	tasks.TryAdd(runningTask, runningTask);
	#pragma warning disable CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
	runningTask.ContinueWith(t =>
	{
	Task toBeRemoved;
	tasks.TryRemove(t, out toBeRemoved);
	}, TaskContinuationOptions.ExecuteSynchronously);
	#pragma warning restore CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
	}

	return Task.WhenAll(tasks.Values);
	}

	[Benchmark]
	public Task ContinueWithWithoutClojureCapture()
	{
	for (int i = 0; i < NumberOfTasks; i++)
	{
	var runningTask = Task.Delay(1);
	tasks.TryAdd(runningTask, runningTask);
	#pragma warning disable CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
	runningTask.ContinueWith((t, state) =>
	{
	var runningTasks = (ConcurrentDictionary<Task, Task>) state;
	Task toBeRemoved;
	runningTasks.TryRemove(t, out toBeRemoved);
	}, tasks, TaskContinuationOptions.ExecuteSynchronously);
	#pragma warning restore CS4014 // Because this call is not awaited, execution of the current method continues before the call is completed
	}

	return Task.WhenAll(tasks.Values);
	}
	}
Method	NumberOfTasks	Median	StdDev	Gen 0	Gen 1	Gen 2	Bytes Allocated/Op
ContinueWithClojureCapture	1	44.7095 us	2.8989 us	23.32	17.69	-	2,714.27
ContinueWithWithoutClojureCapture	1	46.3050 us	2.5083 us	24.68	14.88	-	2,581.80
ContinueWithClojureCapture	5	100.6687 us	3.3937 us	52.89	36.32	-	6,442.19
ContinueWithWithoutClojureCapture	5	98.7882 us	5.3014 us	51.51	44.11	-	6,812.53
ContinueWithClojureCapture	10	131.7470 us	6.3743 us	78.00	59.00	-	10,302.84
ContinueWithWithoutClojureCapture	10	132.9372 us	9.7847 us	82.84	61.36	0.51	10,675.89