mono/tests/sgen-new-threads-dont-join-stw.cs

   1 using System;
   2 using System.Timers;
   3 using System.Threading;
   4 using System.Collections;
   5 using System.Collections.Generic;
   6
   7 class T {
   8
   9     static int count = 0;
  10     static object count_lock = new object();
  11
  12     const long N = 500000;
  13     const int num_threads = 8;
  14
  15     static void UseMemory () {
  16
  17         for (int i = 0; i < N; ++i) {
  18
  19             var l1 = new ArrayList ();
  20             l1.Add(""+i);
  21             var l2 = new ArrayList ();
  22             l2.Add(""+(i+1));
  23             var l3 = new ArrayList ();
  24             l3.Add(""+(i+2));
  25             var l4 = new ArrayList ();
  26             l4.Add(""+(i+3));
  27         }
  28
  29
  30         lock (count_lock)
  31         {
  32             count++;
  33             Monitor.PulseAll(count_lock);
  34         }
  35     }
  36
  37     static void Timer_Elapsed(object sender, EventArgs e)
  38     {
  39         HashSet<string> h = new HashSet<string>();
  40         for (int j = 0; j < 10000; j++)
  41         {
  42             h.Add(""+j+""+j);
  43         }
  44     }
  45
  46     static void Main (string[] args) {
  47         var testTimeout = new TestTimeout ();
  48         testTimeout.Start ();
  49
  50         const int TOTAL_ITERATIONS = 2;
  51         for (int j = 0; j < TOTAL_ITERATIONS; j++)
  52         {
  53             count = 0;
  54
  55             List<Thread> threads = new List<Thread>();
  56             List<System.Timers.Timer> timers = new List<System.Timers.Timer>();
  57
  58             for (int i = 0; i < num_threads; i++)
  59             {
  60                 Thread t3 = new Thread (delegate () {
  61                     UseMemory();
  62                     });
  63
  64                 t3.Start ();
  65
  66                 System.Timers.Timer timer = new System.Timers.Timer();
  67                 timer.Elapsed += Timer_Elapsed;
  68                 timer.AutoReset = false;
  69                 timer.Interval = 1000;
  70                 timer.Start();
  71                 timers.Add(timer);
  72             }
  73
  74             for (int i = 0; i < 4000; i++)
  75             {
  76                 System.Timers.Timer timer = new System.Timers.Timer();
  77                 timer.Elapsed += Timer_Elapsed;
  78                 timer.AutoReset = false;
  79                 timer.Interval = 500;
  80                 timer.Start();
  81                 timers.Add(timer);
  82             }
  83
  84             lock (count_lock)
  85             {
  86                 while (count < num_threads)
  87                 {
  88                     Console.Write (".");
  89                     Monitor.Wait(count_lock);
  90                 }
  91             }
  92
  93             foreach (var t in threads)
  94             {
  95                 t.Join();
  96             }
  97
  98             Console.WriteLine ();
  99             if (!testTimeout.HaveTimeLeft ()) {
 100                     var finishTime = DateTime.UtcNow;
 101                     var ranFor = finishTime - testTimeout.StartTime;
 102                     Console.WriteLine ("Will run out of time soon.  ran for {0}, finished {1}/{2} iterations", ranFor, j+1, TOTAL_ITERATIONS);
 103             }
 104         }
 105
 106         Console.WriteLine ("done");
 107     }
 108 }