Attachment 400512 Details for Bug 653928

Updated -- C# code file containing repro code as described.

TestDelegateBeginInvoke.cs (text/plain), 7.58 KB, created by Andy Hume on 2010-11-16 13:55:08 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Andy Hume

Created: 2010-11-16 13:55:08 UTC

Size: 7.58 KB

patch

obsolete

>ï»¿using System;
>using System.Threading;
>using System.Windows.Forms;
>
>public class TestDelegateBeginInvoke
>{
>    static void DoTestDelegateBeginInvoke(string name)
>    {
>        WaitCallback dlgt = Runner;
>        Console_WriteLine("Gonna call Delegate.BeginInvoke...");
>        var ar = dlgt.BeginInvoke(BuildName(name, "D.BI"), null, null);
>        Console_WriteLine("BeginInvoke returned.");
>        bool completed = false;
>        for (int i = 0; i < 10; ++i) {
>            Thread.Sleep(1000);
>            completed = ar.IsCompleted;
>            if (completed) {
>                Console_WriteLine("Delegate Completed :-)");
>                break;
>            }
>            Console.Write(i + ". ");
>        }
>        Console_WriteLine();
>        if (!completed) {
>            Console_WriteLine("Delegate did NOT complete!!!");
>        }
>        //:dlgt.EndInvoke(ar);
>    }
>
>    static void DoTestQueueUserWorkItem(string name)
>    {
>        WaitCallback dlgt = Runner;
>        Console_WriteLine("Gonna call ThreadPool.QueueUserWorkItem...");
>        ThreadPool.QueueUserWorkItem(dlgt, BuildName(name, "QUWI"));
>        // Fire and forget, so delay a little for completion (hopefully!).
>        Thread.Sleep(500);
>    }
>
>    static string BuildName(string parent, string current)
>    {
>        return parent + "->" + current;
>    }
>
>    static void Runner(object state)
>    {
>
>        Console_WriteLine("   I'm the runner for " + state + "... "
>            + GetThreadIdInfo());
>        //
>        Console_WriteLine("   Runner ended.");
>    }
>
>    //----------------------------------------------------
>    static void Main(string[] args)
>    {
>        Console.WriteLine(GetThreadIdInfo());
>        SimpleTestOuterQuwiInnerQuwi();
>        SimpleTest();
>        SimpleTestOuterQuwi();
>        Console_Pause();
>        //
>        FullTest();
>        //
>        Console_WriteLine();
>        Console_WriteLine("--------------------");
>        Console_WriteLine("Exiting program...");
>    }
>
>    static void SimpleTest()
>    {
>        Console.WriteLine("--------------------");
>        Console.WriteLine("* SimpleTest");
>        int msForOuterToDelay = 2000;
>        //
>        WaitCallback inner = delegate {
>            Console_WriteLine("    Inner: Was I called only **after** Outer exited?????? " + GetThreadIdInfo());
>        };
>        //
>        WaitCallback outer = delegate {
>            Console_WriteLine("Outer: calling inner.BeginInvoke " + GetThreadIdInfo());
>            var arI = inner.BeginInvoke(null, null, null);
>            //
>            Console_WriteLine("Outer: pausing...");
>            Thread.Sleep(msForOuterToDelay);
>            Console_WriteLine("Outer: exiting...");
>        };
>        //
>        Console_WriteLine("Calling outer.BeginInvoke");
>        var arO = outer.BeginInvoke(null, null, null);
>        //
>        Thread.Sleep(msForOuterToDelay);
>        Thread.Sleep(msForOuterToDelay);
>    }
>
>    static void SimpleTestOuterQuwi()
>    {
>        Console.WriteLine("--------------------");
>        Console.WriteLine("* SimpleTestOuterQuwi");
>        int msForOuterToDelay = 2000;
>        //
>        WaitCallback inner = delegate {
>            Console_WriteLine("    Inner: Was I called only **after** Outer exited?????? " + GetThreadIdInfo());
>        };
>        //
>        WaitCallback outer = delegate {
>            Console_WriteLine("Outer: calling inner.BeginInvoke " + GetThreadIdInfo());
>            var arI = inner.BeginInvoke(null, null, null);
>            //
>            Console_WriteLine("Outer: pausing...");
>            Thread.Sleep(msForOuterToDelay);
>            Console_WriteLine("Outer: exiting...");
>        };
>        //
>        Console_WriteLine("Calling QueueUserWorkItem(outer)");
>        ThreadPool.QueueUserWorkItem(outer, null);
>        //
>        Thread.Sleep(msForOuterToDelay);
>        Thread.Sleep(msForOuterToDelay);
>    }
>
>    static void SimpleTestOuterQuwiInnerQuwi()
>    {
>        Console.WriteLine("--------------------");
>        Console.WriteLine("* SimpleTestOuterQuwiInnerQuwi");
>        int msForOuterToDelay = 2000;
>        //
>        WaitCallback inner = delegate {
>            Console_WriteLine("    Inner: Was I called only **after** Outer exited?????? " + GetThreadIdInfo());
>        };
>        //
>        WaitCallback outer = delegate {
>            Console_WriteLine("Outer: calling QueueUserWorkItem(inner) " + GetThreadIdInfo());
>            ThreadPool.QueueUserWorkItem(inner, null);
>            //
>            Console_WriteLine("Outer: pausing...");
>            Thread.Sleep(msForOuterToDelay);
>            Console_WriteLine("Outer: exiting...");
>        };
>        //
>        Console_WriteLine("Calling QueueUserWorkItem(outer)");
>        ThreadPool.QueueUserWorkItem(outer, null);
>        //
>        Thread.Sleep(msForOuterToDelay);
>        Thread.Sleep(msForOuterToDelay);
>    }
>
>    static void FullTest()
>    {
>        WaitCallback doIt = delegate(object state) {
>            var name = (string)state;
>            DoTestDelegateBeginInvoke(name);
>            DoTestQueueUserWorkItem(name);
>        };
>        //
>        Console_WriteLine("--------------------");
>        Console_WriteLine("* Run tests directly...");
>        doIt("Direct");
>        //
>#if false
>        Console_WriteLine();
>        Console_WriteLine("--------------------");
>        Console_WriteLine("* Run tests in WinForms...");
>        var f = new Form();
>        f.Load += delegate (object sender, EventArgs e) {
>            Console_WriteLine("In Form.Load...");
>            doIt("SWF");
>            Console_WriteLine("Form.Load done");
>            ((Form)sender).Close();
>        };
>        Application.Run(f);
>#endif
>        //
>        Console_WriteLine();
>        Console_WriteLine("--------------------");
>        Console_WriteLine("* Run tests from ThreadPool...");
>        ThreadPool.QueueUserWorkItem(doIt, "QUWI");
>        Thread.Sleep(2000);
>        //
>        Console_WriteLine();
>        Console_WriteLine("--------------------");
>        Console_WriteLine("* Run tests from another Delegate.BeginInvoke...");
>        WaitCallback outerDelegate = delegate {
>            Console_WriteLine("In OUTER Delegate.BeginInvoke...");
>            doIt("OuterD.Bi");
>            Console_WriteLine("OUTER Delegate.BeginInvoke done");
>        };
>        var ar = outerDelegate.BeginInvoke(null, null, null);
>        Thread.Sleep(2000);
>        //
>        Console_WriteLine();
>        Console_WriteLine("--------------------");
>        Console_WriteLine("* Run tests from a manual Thread...");
>        ParameterizedThreadStart outerThread = delegate(object state) {
>            var name = (string)state;
>            Console_WriteLine("In OUTER Delegate.BeginInvoke...");
>            doIt(name);
>            Console_WriteLine("OUTER Delegate.BeginInvoke done");
>        };
>        var t = new Thread(outerThread);
>        t.Start("new_Thread");
>        Console_WriteLine("(Started, gonna Join...)");
>        t.Join();
>        //
>        //
>        Console_Pause();
>    }
>
>    //------------
>    static string GetThreadIdInfo()
>    {
>        return " [TID: " + Thread.CurrentThread.ManagedThreadId.ToString("X") + "]";
>    }
>
>    static void Console_WriteLine()
>    {
>        Console.WriteLine();
>    }
>
>    static void Console_WriteLine(string s)
>    {
>        var t = Environment.TickCount;
>        Console.WriteLine(t + ": " + s);
>    }
>
>    static void Console_Pause()
>    {
>        Console.WriteLine("Hit return when ready to continue>");
>        Console.ReadLine();
>    }
>}

Actions: View

Attachments on bug 653928: 400473 | 400512