mono/tests/thread-suspend-suspended.cs

   1
   2 using System;
   3 using System.Runtime.CompilerServices;
   4 using System.Threading;
   5
   6 class Driver
   7 {
   8
   9         public static void Main ()
  10         {
  11                 bool finished = false;
  12                 AutoResetEvent start_gc = new AutoResetEvent (false);
  13                 AutoResetEvent finished_gc = new AutoResetEvent (false);
  14
  15                 Thread t1 = new Thread (() => {
  16                         while (!Volatile.Read(ref finished)) {}
  17                 });
  18
  19                 Thread t2 = new Thread (() => {
  20                         while (!Volatile.Read(ref finished)) {
  21                                 if (start_gc.WaitOne (0)) {
  22                                         GC.Collect ();
  23                                         finished_gc.Set ();
  24                                 }
  25
  26                                 Thread.Yield ();
  27                         }
  28                 });
  29
  30                 t1.Start ();
  31                 t2.Start ();
  32
  33                 Thread.Sleep (10);
  34
  35                 for (int i = 0; i < 50 * 40 * 5; ++i) {
  36                         t1.Suspend ();
  37                         start_gc.Set ();
  38                         finished_gc.WaitOne ();
  39                         t1.Resume ();
  40
  41                         if ((i + 1) % (50) == 0)
  42                                 Console.Write (".");
  43                         if ((i + 1) % (50 * 40) == 0)
  44                                 Console.WriteLine ();
  45                 }
  46
  47                 Volatile.Write(ref finished, true);
  48
  49                 t1.Join ();
  50                 t2.Join ();
  51         }
  52 }