danielmarbach

namespace ServiceControl.Migrations
{
using System;
using System.Threading.Tasks;
using Raven.Abstractions;
using Raven.Abstractions.Data;
using ServiceBus.Management.Infrastructure.Settings;
using ServiceControl.Contracts.Operations;
using ServiceControl.MessageFailures;

danielmarbach

namespace Server
{
    public class Handler : IHandleMessages<SynchroniseSite>
    {
        public IProvideSites SiteProvider { get; set; }
        public async Task Handle(SynchroniseSite message, IMessageHandlerContext context)
        {
            try
            {
                List<Data> data = new List<Data>();

danielmarbach

    [Config(typeof(Config))]
    public class ContinueWithAllocations
    {
        private class Config : ManualConfig
        {
            public Config()
            {
                Add(new MemoryDiagnoser());
            }
        }

danielmarbach

<m:error xmlns:m="http://schemas.microsoft.com/ado/2007/08/dataservices/metadata">
<m:code/>
<m:message xml:lang="en-US">An error occurred while processing this request.</m:message>
<m:innererror>
<m:message>
Exception has been thrown by the target of an invocation.
</m:message>
<m:type>System.Reflection.TargetInvocationException</m:type>
<m:stacktrace>
at System.RuntimeMethodHandle.InvokeMethod(Object target, Object[] arguments, Signature sig, Boolean constructor)

danielmarbach

[user]
	email = daniel.marbach@openplace.net
	name = danielmarbach
[merge]
	tool = kdiff3
[diff]
	guitool = kdiff3
[core]
	autocrlf = False
	editor = \"C:/Program Files (x86)/GitExtensions/GitExtensions.exe\" fileeditor

danielmarbach

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace PushCollection
{

danielmarbach

public static class TaskExtensions
    {
        public static Task<TResult> WaitWithCancellation<TResult>(this Task<TResult> task, CancellationToken token = default(CancellationToken))
        {
            var tcs = new TaskCompletionSource<TResult>();
            var registration = token.Register(s =>
            {
                var source = (TaskCompletionSource<TResult>) s;
                source.TrySetCanceled();
            }, tcs);

danielmarbach

class Program
    {
        private static int numberOfMessages;

        static void Main(string[] args)
        {
            File.Delete("./sync.txt");
            File.Delete("./async.txt");

            numberOfMessages = 1000;

danielmarbach

using System;
using System.Diagnostics;
using System.Threading.Tasks;

namespace AsyncSandbox
{
    class Program
    {
        static async Task Main(string[] args)
        {

danielmarbach

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

namespace test
{
    class Program
    {
        static async Task Main(string[] args)
        {