kevingosse

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

namespace ConsoleApp1
{
    class Program
    {
        private static Task _sharedTask;

kevingosse

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

namespace ConsoleApp1
{
    class Program
    {
        private static ManualResetEventSlim _mutex = new ManualResetEventSlim();
        private static Task _sharedTask;

kevingosse

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

namespace ConsoleApp1
{
    class Program
    {
        private static ManualResetEventSlim _mutex = new ManualResetEventSlim();
        private static Task _sharedTask;

kevingosse

[DllExport("helloworld")]
public static void HelloWorld(IntPtr client, [MarshalAs(UnmanagedType.LPStr)] string args)
{
    DebuggingContext.Execute(client, args, HelloWorld);
}

private static void HelloWorld(ClrRuntime runtime, string args)
{
    Console.WriteLine("The first 10 types on the heap are: ");

kevingosse

[DllExport("helloworld")]
public static void HelloWorld(IntPtr client, [MarshalAs(UnmanagedType.LPStr)] string args)
{
}

kevingosse

public static void HelloWorld(IntPtr client, [MarshalAs(UnmanagedType.LPStr)] string args)
{
}

kevingosse

protected override void QueueTask(Task task)
{
    MutateState(task);

    var newScheduler = new ThreadPoolTaskScheduler();

    typeof(Task).GetField("m_taskScheduler", BindingFlags.Instance | BindingFlags.NonPublic)
        .SetValue(task, newScheduler);

    ThreadPool.UnsafeQueueUserWorkItem(t => newScheduler.ExecuteTask((Task)t), task);

kevingosse

class Program
{
    static void Main(string[] args)
    {
        Task.Run(Test);

        Console.ReadLine();
    }

    static async Task Test()

kevingosse

var continuationWrapper = func.Target;

var continuation = continuationWrapper.GetType().GetField("_continuation", BindingFlags.Instance | BindingFlags.NonPublic)
    .GetValue(continuationWrapper) as Action;

if (continuation != null)
{
    var asyncStateMachineBox = continuation.Target;

    var stateMachineField = asyncStateMachineBox?.GetType().GetField("StateMachine");

kevingosse

private void MutateState(Task task)
{
    var continuationWrapperType = Type.GetType("System.Runtime.CompilerServices.AsyncMethodBuilderCore+ContinuationWrapper");

    var taskAction = typeof(Task).GetField("m_action", BindingFlags.Instance | BindingFlags.NonPublic)
        .GetValue(task);

    Delegate func = task.AsyncState as Delegate ?? taskAction as Delegate;

    if (func?.Target?.GetType() == continuationWrapperType)