StephenCleary

public sealed class MyObject : IDisposable
{
    /// <summary>
    /// Used by the pool.
    /// </summary>
    private MyObject _next;

    // TODO: Add other members here.

    public static MyObject Create()

StephenCleary

static void Main(string[] args)
{
    int threadId = Task.Run(() =>
    {
        CallContext.LogicalSetData("k", 0);
        Console.WriteLine("Write logical data on thread " + Thread.CurrentThread.ManagedThreadId);
        return Thread.CurrentThread.ManagedThreadId;
    }).Result;

    while (true)

StephenCleary

using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.VisualStudio.TestTools.UnitTesting;

[TestClass]
public class StartNewCancellationTokenUnitTests
{
    [TestMethod]
    public void CancellationTokenPassedToStartNew_CancelsTaskWithTaskCanceledException()

StephenCleary

// I'm starting 10 calls at every 50 msec. Each call has a random execution time between 1-19 seconds.
// Many times the last answer comes from the 9th call instead of the 10th.

// I'm not sure I'm testing it properly.

void Main()
{
    var rand = new Random();
    
    Enumerable.Range(1,10)

StephenCleary

using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.VisualStudio.TestTools.UnitTesting;

[TestClass]
public class AwaitCanJustCatchOperationCanceledException
{
    [TestMethod]
    public async Task CancellationTokenPassedToStartNew_CanTreatAsOperationCanceledException()

StephenCleary

using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.VisualStudio.TestTools.UnitTesting;

[TestClass]
public class WaitCanTreatInnerExceptionAsOperationCanceledException
{
    [TestMethod]
    public void CancellationTokenPassedToStartNew_CanTreatAsOperationCanceledException()

StephenCleary

using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.VisualStudio.TestTools.UnitTesting;

[TestClass]
public class TaskRunCancellationTokenUnitTests
{
    [TestMethod]
    public void CancellationTokenPassedToSynchronousTaskRun_CancelsTaskWithTaskCanceledException()

StephenCleary

internal class AwaitableMessages
{
    public static Task<T> NextMessageAsync<T>()
    {
        var tcs = new TaskCompletionSource<T>();
        Messenger.Default.Register<T>(null, item => tcs.TrySetResult(item));
        return tcs.Task;
    }
}

StephenCleary

using System;
using System.Runtime.CompilerServices;
using System.Threading.Tasks;

// The more evil version. :)

class Program
{
    static void Main(string[] args)
    {

StephenCleary

using System;
using System.Threading;

/// <summary>
/// A base class for disposables that need exactly-once semantics in a threadsafe way. All disposals of this instance block until the disposal is complete.
/// </summary>
/// <remarks>
/// <para>If <see cref="Dispose()"/> is called multiple times, only the first call will execute the disposal code. Other calls to <see cref="Dispose()"/> will wait for the disposal to complete.</para>
/// </remarks>
public sealed class AnonymousDisposable : IDisposable