StephenCleary

using System;
using System.Linq;
using System.Threading.Tasks;

// Target: .NET 4.5 Client (or Full)
// Add a reference to System.Threading.Tasks.Dataflow

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

StephenCleary

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

/// <summary>
/// Provides support for asynchronous lazy initialization. This type is fully threadsafe.
/// </summary>
/// <typeparam name="T">The type of object that is being asynchronously initialized.</typeparam>
public sealed class AsyncLazy<T>
{

StephenCleary

Id collision!
  task.Id == other.Id: True
  task == other: False

StephenCleary

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Reflection;
using System.Threading.Tasks;

namespace DisplayAsyncAPIs
{
    class Program

StephenCleary

Simple WebAPI app with Console client that shows that async methods do release threads to the thread pool.

StephenCleary

java.lang.RuntimeException: org.apache.cxf.interceptor.Fault: Could not send Message.
  org.apache.cxf.interceptor.AbstractFaultChainInitiatorObserver.onMessage(AbstractFaultChainInitiatorObserver.java:110)
	org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:323)
	org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:123)
	org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:207)
	org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:213)
	org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:154)
	org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:126)
	org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:185)
	org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet(AbstractHTTPServlet.java:113)

StephenCleary

using System;
using System.Threading.Tasks;

namespace Nito.AsyncEx
{
    /// <summary>
    /// A progress implementation that sends progress reports to an observer stream. Optionally ends the stream when the task completes.
    /// </summary>
    /// <typeparam name="T">The type of progress value.</typeparam>
    internal sealed class ObserverProgress<T> : IProgress<T>

StephenCleary

using System;
using System.Collections;
using System.Diagnostics;
using System.IO;
using System.IO.Compression;
using System.Linq;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
using System.Text;
using Comparers;

StephenCleary

using System.Collections;
using System.Collections.Generic;
using System.Linq;

namespace Voron.Util
{
    public class LinkedDictionary<TKey, TValue> : IEnumerable<KeyValuePair<TKey, TValue>>, IReadOnlyDictionary<TKey, TValue>
        where TValue : class, new()
    {
        private readonly TValue _deleteMarker = new TValue();

StephenCleary

using System;
using System.Reactive.Linq;
using System.Threading;

/// <summary>
/// Helper methods for using observable <see cref="IProgress{T}"/> implementations. These are hot observables.
/// </summary>
public static class ObservableProgress
{
    /// <summary>