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	100	484.2225 us	22.7719 us	37.17	30.81	-	41,458.70
ContinueWithWithoutClojureCapture	100	482.6122 us	23.7498 us	39.73	30.97	0.29	44,206.16
ContinueWithClojureCapture	200	761.7816 us	29.4267 us	53.99	45.99	4.00	61,399.55
ContinueWithWithoutClojureCapture	200	770.7198 us	27.5776 us	51.09	51.47	1.91	62,713.22
ContinueWithClojureCapture	500	1,484.0111 us	68.0056 us	84.47	117.62	12.63	125,423.96
ContinueWithWithoutClojureCapture	500	1,426.5611 us	66.3615 us	86.00	87.00	10.00	108,241.09
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