mcs/class/corlib/Test/System.Threading/ThreadTest.cs

   1 // ThreadTest.cs - NUnit Test Cases for the System.Threading.Thread class
   2 //
   3 // Authors
   4 //      Eduardo Garcia Cebollero (kiwnix@yahoo.es)
   5 //      Sebastien Pouliot  <sebastien@ximian.com>
   6 //
   7 // (C) Eduardo Garcia Cebollero.
   8 // (C) Ximian, Inc.  http://www.ximian.com
   9 // (C) 2004 Novell (http://www.novell.com)
  10 //
  11
  12 using System;
  13 using System.Globalization;
  14 using System.Security.Principal;
  15 using System.Threading;
  16
  17 using NUnit.Framework;
  18
  19 namespace MonoTests.System.Threading
  20 {
  21         // These tests seem to hang the 2.0 framework. So they are disabled for now
  22         // Don't reenable them until you can run a few thousand times on an SMP box.
  23         [Category ("NotWorking")]
  24         public class ThreadedPrincipalTest
  25         {
  26                 public static void NoPrincipal ()
  27                 {
  28 #if !TARGET_JVM // AppDomain.SetPrincipalPolicy not supported for TARGET_JVM
  29                         AppDomain.CurrentDomain.SetPrincipalPolicy (PrincipalPolicy.NoPrincipal);
  30 #endif
  31                         IPrincipal p = Thread.CurrentPrincipal;
  32                         Assert.IsNull (p, "#1");
  33
  34                         Thread.CurrentPrincipal = new GenericPrincipal (new GenericIdentity ("mono"), null);
  35                         Assert.IsNotNull (Thread.CurrentPrincipal, "#2");
  36
  37                         Thread.CurrentPrincipal = null;
  38                         Assert.IsNull (Thread.CurrentPrincipal, "#3");
  39                         // in this case we can return to null
  40                 }
  41
  42 #if !TARGET_JVM // AppDomain.SetPrincipalPolicy not supported for TARGET_JVM
  43                 public static void UnauthenticatedPrincipal ()
  44                 {
  45                         AppDomain.CurrentDomain.SetPrincipalPolicy (PrincipalPolicy.UnauthenticatedPrincipal);
  46                         IPrincipal p = Thread.CurrentPrincipal;
  47                         Assert.IsNotNull (p, "#1");
  48                         Assert.IsTrue ((p is GenericPrincipal), "#2");
  49                         Assert.AreEqual (String.Empty, p.Identity.Name, "#3");
  50                         Assert.AreEqual (String.Empty, p.Identity.AuthenticationType, "#4");
  51                         Assert.IsFalse (p.Identity.IsAuthenticated, "#5");
  52
  53                         Thread.CurrentPrincipal = new GenericPrincipal (new GenericIdentity ("mono"), null);
  54                         Assert.IsNotNull (Thread.CurrentPrincipal, "#6");
  55
  56                         Thread.CurrentPrincipal = null;
  57                         Assert.IsNotNull (Thread.CurrentPrincipal, "#7");
  58                         // in this case we can't return to null
  59                 }
  60
  61                 public static void WindowsPrincipal ()
  62                 {
  63                         AppDomain.CurrentDomain.SetPrincipalPolicy (PrincipalPolicy.WindowsPrincipal);
  64                         IPrincipal p = Thread.CurrentPrincipal;
  65                         Assert.IsNotNull (p, "#1");
  66                         Assert.IsTrue ((p is WindowsPrincipal), "#2");
  67                         Assert.IsNotNull (p.Identity.Name, "#3");
  68                         Assert.IsNotNull (p.Identity.AuthenticationType, "#4");
  69                         Assert.IsTrue (p.Identity.IsAuthenticated, "#5");
  70
  71                         // note: we can switch from a WindowsPrincipal to a GenericPrincipal
  72                         Thread.CurrentPrincipal = new GenericPrincipal (new GenericIdentity ("mono"), null);
  73                         Assert.IsNotNull (Thread.CurrentPrincipal, "#6");
  74
  75                         Thread.CurrentPrincipal = null;
  76                         Assert.IsNotNull (Thread.CurrentPrincipal, "#7");
  77                         // in this case we can't return to null
  78                 }
  79 #endif // TARGET_JVM
  80
  81                 public static void CopyOnNewThread ()
  82                 {
  83                         Assert.IsNotNull (Thread.CurrentPrincipal, "#1");
  84                         Assert.AreEqual ("good", Thread.CurrentPrincipal.Identity.Name, "#2");
  85                 }
  86         }
  87
  88         [TestFixture]
  89         public class ThreadTest
  90         {
  91                 TimeSpan Infinite = new TimeSpan (-10000);      // -10000 ticks == -1 ms
  92                 TimeSpan SmallNegative = new TimeSpan (-2);     // between 0 and -1.0 (infinite) ms
  93                 TimeSpan Negative = new TimeSpan (-20000);      // really negative
  94                 TimeSpan MaxValue = TimeSpan.FromMilliseconds ((long) Int32.MaxValue);
  95                 TimeSpan TooLarge = TimeSpan.FromMilliseconds ((long) Int32.MaxValue + 1);
  96
  97                 static bool is_win32;
  98                 static bool is_mono;
  99
 100                 static ThreadTest ()
 101                 {
 102                         switch (Environment.OSVersion.Platform) {
 103                         case PlatformID.Win32NT:
 104                         case PlatformID.Win32S:
 105                         case PlatformID.Win32Windows:
 106                         case PlatformID.WinCE:
 107                                 is_win32 = true;
 108                                 break;
 109                         }
 110
 111                         // check a class in mscorlib to determine if we're running on Mono
 112                         if (Type.GetType ("System.MonoType", false) != null)
 113                                 is_mono = true;
 114                 }
 115
 116                 //Some Classes to test as threads
 117                 private class C1Test
 118                 {
 119                         public int cnt;
 120                         public Thread thread1;
 121                         public bool endm1;
 122                         public bool endm2;
 123
 124                         public C1Test()
 125                         {
 126                                 thread1 = (Thread)null;
 127                                 this.cnt = 0;
 128                                 endm1 = endm2 = false;
 129                         }
 130
 131                         public void TestMethod()
 132                         {
 133                                 while (cnt < 10)
 134                                 {
 135                                         cnt++;
 136                                 }
 137                                 endm1 = true;
 138                         }
 139                         public void TestMethod2()
 140                         {
 141                                 if (!(thread1==(Thread)null) )
 142                                 {
 143                                         thread1.Join();
 144                                 }
 145                                 endm2 = true;
 146                         }
 147                 }
 148
 149                 private class C2Test
 150                 {
 151                         public int cnt;
 152                         public bool run = false;
 153
 154                         public C2Test()
 155                         {
 156                                 this.cnt = 0;
 157                         }
 158
 159                         public void TestMethod()
 160                         {
 161                                 run = true;
 162                                 while (true)
 163                                 {
 164                                         if (cnt < 1000)
 165                                                 cnt++;
 166                                         else
 167                                                 cnt = 0;
 168                                 }
 169                         }
 170                 }
 171
 172                 private class C3Test
 173                 {
 174                         public C1Test sub_class;
 175                         public Thread sub_thread;
 176
 177                         public C3Test()
 178                         {
 179                                 sub_class = new C1Test();
 180                                 sub_thread = new Thread(new ThreadStart(sub_class.TestMethod));
 181                         }
 182
 183                         public void TestMethod1()
 184                         {
 185                                 sub_thread.Start();
 186                                 Thread.Sleep (100);
 187                                 sub_thread.Abort();
 188                         }
 189                 }
 190
 191                 private class C4Test
 192                 {
 193                         public C1Test class1;
 194                         public C1Test class2;
 195                         public Thread thread1;
 196                         public Thread thread2;
 197                         public bool T1ON ;
 198                         public bool T2ON ;
 199
 200                         public C4Test()
 201                         {
 202                                 T1ON = false;
 203                                 T2ON = false;
 204                                 class1 = new C1Test();
 205                                 class2 = new C1Test();
 206                                 thread1 = new Thread(new ThreadStart(class1.TestMethod));
 207                                 thread2 = new Thread(new ThreadStart(class2.TestMethod));
 208                         }
 209
 210                         public void TestMethod1()
 211                         {
 212                                 thread1.Start();
 213                                 TestUtil.WaitForAlive (thread1, "wait1");
 214                                 T1ON = true;
 215                                 thread2.Start();
 216                                 TestUtil.WaitForAlive (thread2, "wait2");
 217                                 T2ON = true;
 218                                 thread1.Abort();
 219                                 TestUtil.WaitForNotAlive (thread1, "wait3");
 220                                 T1ON = false;
 221                                 thread2.Abort();
 222                                 TestUtil.WaitForNotAlive (thread2, "wait4");
 223                                 T2ON = false;
 224                         }
 225
 226                         public void TestMethod2()
 227                         {
 228                                 thread1.Start();
 229                                 thread1.Join();
 230                         }
 231                 }
 232
 233                 [Test]
 234                 public void TestCtor1()
 235                 {
 236                         C1Test test1 = new C1Test();
 237                         Thread t = new Thread (new ThreadStart (test1.TestMethod));
 238
 239                         Assert.IsTrue (t.CurrentCulture.IsReadOnly, "CurrentCulture.IsReadOnly");
 240                         Assert.IsFalse (t.IsAlive, "IsAlive");
 241                         Assert.IsFalse (t.IsBackground, "IsBackground");
 242                         Assert.IsNull (t.Name, "Name");
 243                         Assert.AreEqual (ThreadState.Unstarted, t.ThreadState, "ThreadState");
 244                 }
 245
 246                 [Test]
 247                 [Category ("NotWorking")] // we're not sharing (read-only) CultureInfo
 248                 public void CultureInfo_Shared_Across_Threads ()
 249                 {
 250                         Thread t = new Thread (TestCtor1);
 251                         Assert.AreSame (t.CurrentCulture, t.CurrentUICulture, "Culture");
 252
 253                         Assert.AreSame (t.CurrentCulture, CultureInfo.CurrentCulture, "CultureInfo.CurrentCulture");
 254                         Assert.AreSame (t.CurrentUICulture, CultureInfo.CurrentUICulture, "CultureInfo.CurrentUICulture");
 255
 256                         Assert.AreSame (t.CurrentCulture, Thread.CurrentThread.CurrentCulture, "Thread.CurrentThread.CurrentCulture");
 257                         Assert.AreSame (t.CurrentUICulture, Thread.CurrentThread.CurrentUICulture, "Thread.CurrentThread.CurrentUICulture");
 258                 }
 259
 260                 [Test] // bug #325566
 261                 public void GetHashCodeTest ()
 262                 {
 263                         C1Test test1 = new C1Test ();
 264                         Thread tA = new Thread (new ThreadStart (test1.TestMethod));
 265                         int hA1 = tA.GetHashCode ();
 266 #if NET_2_0
 267                         Assert.IsTrue (hA1 > 0, "#A1");
 268 #endif
 269                         tA.Start ();
 270                         int hA2 = tA.GetHashCode ();
 271                         Assert.AreEqual (hA1, hA2, "#A2");
 272                         tA.Join ();
 273                         int hA3 = tA.GetHashCode ();
 274                         Assert.AreEqual (hA1, hA3, "#A3");
 275 #if NET_2_0
 276                         Assert.AreEqual (hA1, tA.ManagedThreadId, "#A4");
 277 #endif
 278
 279                         test1 = new C1Test ();
 280                         Thread tB = new Thread (new ThreadStart (test1.TestMethod));
 281                         int hB1 = tB.GetHashCode ();
 282 #if NET_2_0
 283                         Assert.IsTrue (hB1 > 0, "#B1");
 284 #endif
 285                         tB.Start ();
 286                         int hB2 = tB.GetHashCode ();
 287                         Assert.AreEqual (hB1, hB2, "#B2");
 288                         tB.Join ();
 289                         int hB3 = tB.GetHashCode ();
 290                         Assert.AreEqual (hB1, hB3, "#B3");
 291 #if NET_2_0
 292                         Assert.AreEqual (hB1, tB.ManagedThreadId, "#B4");
 293 #endif
 294                         Assert.IsFalse (hA2 == hB2, "#B5");
 295                 }
 296
 297 #if NET_2_0
 298                 [Test] // bug #82700
 299                 public void ManagedThreadId ()
 300                 {
 301                         C1Test test1 = new C1Test ();
 302                         Thread t1 = new Thread (new ThreadStart (test1.TestMethod));
 303                         int mtA1 = t1.ManagedThreadId;
 304                         t1.Start ();
 305                         int mtA2 = t1.ManagedThreadId;
 306                         t1.Join ();
 307                         int mtA3 = t1.ManagedThreadId;
 308                         Assert.AreEqual (mtA1, mtA2, "#A1");
 309                         Assert.AreEqual (mtA2, mtA3, "#A2");
 310
 311                         test1 = new C1Test ();
 312                         Thread t2 = new Thread (new ThreadStart (test1.TestMethod));
 313                         int mtB1 = t2.ManagedThreadId;
 314                         t2.Start ();
 315                         int mtB2 = t2.ManagedThreadId;
 316                         t2.Join ();
 317                         int mtB3 = t2.ManagedThreadId;
 318                         Assert.AreEqual (mtB1, mtB2, "#B1");
 319                         Assert.AreEqual (mtB2, mtB3, "#B2");
 320                         Assert.IsFalse (mtB1 == mtA1, "#B3");
 321                 }
 322 #endif
 323
 324                 [Test]
 325                 [Category ("NotDotNet")] // it hangs.
 326                 public void TestStart()
 327                 {
 328                         if (is_win32 && is_mono)
 329                                 Assert.Fail ("This test fails on Win32. The test should be fixed.");
 330                 {
 331                         C1Test test1 = new C1Test();
 332                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 333                         TestThread.Start();
 334                         TestThread.Join();
 335                         Assert.AreEqual (10, test1.cnt, "#1");
 336                 }
 337                 {
 338                         C2Test test1 = new C2Test();
 339                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 340                         TestThread.Start();
 341                         TestThread.Abort();
 342                         try {
 343                                 TestThread.Start();
 344                                 Assert.Fail ("#2");
 345                         } catch (ThreadStateException) {
 346                         }
 347                 }
 348                 {
 349                         C2Test test1 = new C2Test();
 350                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 351                         TestThread.Start();
 352                         while (!test1.run) {
 353                         }
 354                         bool started = (TestThread.ThreadState == ThreadState.Running);
 355                         Assert.AreEqual (started, test1.run, "#15 Thread Is not in the correct state: ");
 356                         TestThread.Abort();
 357                 }
 358                 }
 359
 360                 [Test]
 361                 public void TestApartmentState ()
 362                 {
 363                         if (is_win32 && is_mono)
 364                                 Assert.Fail ("This test fails on mono on win32. Our runtime should be fixed.");
 365
 366                         C2Test test1 = new C2Test();
 367                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 368                         Assert.AreEqual (ApartmentState.Unknown, TestThread.ApartmentState, "#1");
 369                         TestThread.Start();
 370                         TestUtil.WaitForAlive (TestThread, "wait5");
 371 #if NET_2_0
 372                         Assert.AreEqual (ApartmentState.MTA, TestThread.ApartmentState, "#2");
 373 #else
 374                         Assert.AreEqual (ApartmentState.Unknown, TestThread.ApartmentState, "#3");
 375 #endif
 376                         TestThread.Abort();
 377                 }
 378
 379                 [Test]
 380                 public void TestPriority1()
 381                 {
 382                         if (is_win32 && is_mono)
 383                                 Assert.Fail ("This test fails on mono on Win32. Our runtime should be fixed.");
 384
 385                         C2Test test1 = new C2Test();
 386                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 387                         try {
 388                                 TestThread.Priority=ThreadPriority.BelowNormal;
 389                                 ThreadPriority after = TestThread.Priority;
 390                                 TestThread.Start();
 391                                 TestUtil.WaitForAlive (TestThread, "wait7");
 392                                 ThreadPriority before = TestThread.Priority;
 393                                 Assert.AreEqual (before, after, "#41 Unexpected Priority Change: ");
 394                         } finally {
 395                                 TestThread.Abort();
 396                         }
 397                 }
 398
 399                 [Test]
 400                 [Category ("NotDotNet")] // on MS, Thread is still in AbortRequested state when Start is invoked
 401                 public void AbortUnstarted ()
 402                 {
 403                         C2Test test1 = new C2Test();
 404                         Thread th = new Thread (new ThreadStart (test1.TestMethod));
 405                         th.Abort ();
 406                         th.Start ();
 407                 }
 408
 409                 [Test]
 410                 [Category ("NotDotNet")] // on MS, ThreadState is immediately Stopped after Abort
 411                 [Category ("NotWorking")] // this is a MonoTODO -> no support for Priority
 412                 public void TestPriority2()
 413                 {
 414                         C2Test test1 = new C2Test();
 415                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 416                         try {
 417                                 Assert.AreEqual (ThreadPriority.Normal, TestThread.Priority, "#42 Incorrect Priority in New thread: ");
 418                                 TestThread.Start();
 419                                 TestUtil.WaitForAliveOrStop (TestThread, "wait8");
 420                                 Assert.AreEqual (ThreadPriority.Normal, TestThread.Priority, "#43 Incorrect Priority in Started thread: ");
 421                         } finally {
 422                                 TestThread.Abort();
 423                         }
 424                         Assert.AreEqual (ThreadPriority.Normal, TestThread.Priority, "#44 Incorrect Priority in Aborted thread: ");
 425                 }
 426
 427                 [Test]
 428                 [Category ("NotWorking")] // this is a MonoTODO -> no support for Priority
 429                 public void TestPriority3()
 430                 {
 431                         C2Test test1 = new C2Test();
 432                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 433                         try {
 434                                 TestThread.Start();
 435                                 TestThread.Priority = ThreadPriority.Lowest;
 436                                 Assert.AreEqual (ThreadPriority.Lowest, TestThread.Priority, "#45A Incorrect Priority:");
 437                                 TestThread.Priority = ThreadPriority.BelowNormal;
 438                                 Assert.AreEqual (ThreadPriority.BelowNormal, TestThread.Priority, "#45B Incorrect Priority:");
 439                                 TestThread.Priority = ThreadPriority.Normal;
 440                                 Assert.AreEqual (ThreadPriority.Normal, TestThread.Priority, "#45C Incorrect Priority:");
 441                                 TestThread.Priority = ThreadPriority.AboveNormal;
 442                                 Assert.AreEqual (ThreadPriority.AboveNormal, TestThread.Priority, "#45D Incorrect Priority:");
 443                                 TestThread.Priority = ThreadPriority.Highest;
 444                                 Assert.AreEqual (ThreadPriority.Highest, TestThread.Priority, "#45E Incorrect Priority:");
 445                         }
 446                         finally {
 447                                 TestThread.Abort();
 448                         }
 449                 }
 450
 451                 [Test]
 452                 public void TestUndivisibleByPageSizeMaxStackSize ()
 453                 {
 454                         const int undivisible_stacksize = 1048573;
 455
 456                         var thread = new Thread (new ThreadStart (delegate {}), undivisible_stacksize);
 457                         thread.Start ();
 458                         thread.Join ();
 459                 }
 460
 461                 [Test]
 462                 public void TestIsBackground1 ()
 463                 {
 464                         if (is_win32 && is_mono)
 465                                 Assert.Fail ("This test fails on mono on Win32. Our runtime should be fixed.");
 466
 467                         C2Test test1 = new C2Test();
 468                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 469                         try {
 470                                 TestThread.Start();
 471                                 TestUtil.WaitForAlive (TestThread, "wait9");
 472                                 bool state = TestThread.IsBackground;
 473                                 Assert.IsFalse (state, "#51 IsBackground not set at the default state: ");
 474                         } finally {
 475                                 TestThread.Abort();
 476                         }
 477                 }
 478
 479                 [Test]
 480                 public void TestIsBackground2 ()
 481                 {
 482                         C2Test test1 = new C2Test();
 483                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 484                         TestThread.IsBackground = true;
 485                         try {
 486                                 TestThread.Start();
 487                         } finally {
 488                                 TestThread.Abort();
 489                         }
 490
 491                         if (TestThread.IsAlive)
 492                                 Assert.IsTrue (TestThread.IsBackground, "#52 Is Background Changed to Start ");
 493                 }
 494
 495                 [Test]
 496                 public void TestName()
 497                 {
 498                         if (is_win32 && is_mono)
 499                                 Assert.Fail ("This test fails on mono on Win32. Our runtime should be fixed.");
 500
 501                         C2Test test1 = new C2Test();
 502                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 503                         try {
 504                                 TestThread.Start();
 505                                 TestUtil.WaitForAlive (TestThread, "wait10");
 506                                 string name = TestThread.Name;
 507                                 Assert.IsNull (name, "#61 Name set when mustn't be set: ");
 508                                 string newname = "Testing....";
 509                                 TestThread.Name = newname;
 510                                 Assert.AreEqual (newname, TestThread.Name, "#62 Name not set when must be set: ");
 511                         } finally {
 512                                 TestThread.Abort();
 513                         }
 514                 }
 515
 516                 [Test]
 517                 public void Name ()
 518                 {
 519                         Thread t = new Thread (new ThreadStart (Name));
 520                         Assert.IsNull (t.Name, "Name-1");
 521                         t.Name = null;
 522                         Assert.IsNull (t.Name, "Name-2");
 523                 }
 524
 525                 [Test]
 526                 [ExpectedException (typeof (InvalidOperationException))]
 527                 public void ReName ()
 528                 {
 529                         Thread t = new Thread (new ThreadStart (ReName));
 530                         t.Name = "a";
 531                         t.Name = "b";
 532                 }
 533
 534                 [Test]
 535                 public void TestNestedThreads1()
 536                 {
 537                         C3Test test1 = new C3Test();
 538                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod1));
 539                         try {
 540                                 TestThread.Start();
 541                                 TestUtil.WaitForAlive (TestThread, "wait11");
 542                         } finally {
 543                                 TestThread.Abort();
 544                         }
 545                 }
 546
 547                 [Test]
 548                 public void TestNestedThreads2()
 549                 {
 550                         C4Test test1 = new C4Test();
 551                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod1));
 552                         try {
 553                                 TestThread.Start();
 554                         } finally {
 555                                 TestThread.Abort();
 556                         }
 557                 }
 558
 559                 [Test]
 560                 public void TestJoin1()
 561                 {
 562                         C1Test test1 = new C1Test();
 563                         C1Test test2 = new C1Test();
 564                         Thread thread1 = new Thread(new ThreadStart(test1.TestMethod));
 565                         Thread thread2 = new Thread(new ThreadStart(test1.TestMethod2));
 566                         try {
 567                                 thread1.Start();
 568                                 thread2.Start();
 569                                 thread2.Join();
 570                         } finally {
 571                                 thread1.Abort();
 572                                 thread2.Abort();
 573                         }
 574                 }
 575
 576                 [Test]
 577                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 578                 public void Join_Int32_Negative ()
 579                 {
 580                         // -1 is Timeout.Infinite
 581                         Thread.CurrentThread.Join (-2);
 582                 }
 583
 584                 [Test]
 585                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 586                 public void Join_TimeSpan_Negative ()
 587                 {
 588                         Thread.CurrentThread.Join (Negative);
 589                 }
 590
 591                 [Test]
 592                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 593                 public void Join_TimeSpan_TooLarge ()
 594                 {
 595                         Thread.CurrentThread.Join (TooLarge);
 596                 }
 597
 598                 [Test]
 599                 public void Join_TimeSpan_SmallNegative ()
 600                 {
 601                         Thread.CurrentThread.Join (SmallNegative);
 602                 }
 603
 604                 [Test]
 605                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 606                 public void Sleep_Int32_Negative ()
 607                 {
 608                         // -1 is Timeout.Infinite
 609                         Thread.Sleep (-2);
 610                 }
 611
 612                 [Test]
 613                 public void Sleep_TimeSpan_SmallNegative ()
 614                 {
 615                         Thread.Sleep (SmallNegative);
 616                 }
 617
 618                 [Test]
 619                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 620                 public void Sleep_TimeSpan_Negative ()
 621                 {
 622                         Thread.Sleep (Negative);
 623                 }
 624
 625                 [Test]
 626                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 627                 public void Sleep_TimeSpan_TooLarge ()
 628                 {
 629                         Thread.Sleep (TooLarge);
 630                 }
 631
 632                 [Test]
 633                 public void SpinWait ()
 634                 {
 635                         // no exception for negative numbers
 636                         Thread.SpinWait (Int32.MinValue);
 637                         Thread.SpinWait (0);
 638                 }
 639
 640                 [Test]
 641                 public void TestThreadState ()
 642                 {
 643                         if (is_win32 && is_mono)
 644                                 Assert.Fail ("This test fails on mono on Win32. Our runtime should be fixed.");
 645
 646                         //TODO: Test The rest of the possible transitions
 647                         C2Test test1 = new C2Test();
 648                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 649                         Assert.AreEqual (ThreadState.Unstarted, TestThread.ThreadState, "#101 Wrong Thread State");
 650                         try {
 651                                 TestThread.Start();
 652                                 //while(!TestThread.IsAlive); //In the MS Documentation this is not necessary
 653                                                                                           //but in the MS SDK it is
 654                                 Assert.IsTrue (TestThread.ThreadState == ThreadState.Running || (TestThread.ThreadState & ThreadState.Unstarted) != 0,
 655                                         "#102 Wrong Thread State: " + TestThread.ThreadState.ToString ());
 656                         } finally {
 657                                 TestThread.Abort();
 658                         }
 659
 660                         TestUtil.WaitForNotAlive (TestThread, "wait12");
 661                         // Docs say state will be Stopped, but Aborted happens sometimes (?)
 662                         Assert.IsTrue ((ThreadState.Stopped & TestThread.ThreadState) != 0 || (ThreadState.Aborted & TestThread.ThreadState) != 0,
 663                                 "#103 Wrong Thread State: " + TestThread.ThreadState.ToString ());
 664                 }
 665
 666                 [Test]
 667                 [Ignore ("see comment below.")]
 668                 public void CurrentPrincipal_PrincipalPolicy_NoPrincipal ()
 669                 {
 670                         // note: switching from PrincipalPolicy won't work inside the same thread
 671                         // because as soon as a Principal object is created the Policy doesn't matter anymore
 672                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.NoPrincipal));
 673                         try {
 674                                 t.Start ();
 675                                 t.Join ();
 676                         } catch {
 677                                 t.Abort ();
 678                         }
 679                 }
 680
 681 #if !TARGET_JVM // AppDomain.SetPrincipalPolicy not supported for TARGET_JVM
 682                 [Test]
 683                 [Ignore ("see comment below.")]
 684                 public void CurrentPrincipal_PrincipalPolicy_UnauthenticatedPrincipal ()
 685                 {
 686                         // note: switching from PrincipalPolicy won't work inside the same thread
 687                         // because as soon as a Principal object is created the Policy doesn't matter anymore
 688                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.UnauthenticatedPrincipal));
 689                         try {
 690                                 t.Start ();
 691                                 t.Join ();
 692                         } catch {
 693                                 t.Abort ();
 694                         }
 695                 }
 696
 697                 [Test]
 698                 public void CurrentPrincipal_PrincipalPolicy_WindowsPrincipal ()
 699                 {
 700                         // note: switching from PrincipalPolicy won't work inside the same thread
 701                         // because as soon as a Principal object is created the Policy doesn't matter anymore
 702                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.WindowsPrincipal));
 703                         try {
 704                                 t.Start ();
 705                                 t.Join ();
 706                         } catch {
 707                                 t.Abort ();
 708                         }
 709                 }
 710 #endif // TARGET_JVM
 711
 712                 [Test]
 713                 public void IPrincipal_CopyOnNewThread ()
 714                 {
 715                         Thread.CurrentPrincipal = new GenericPrincipal (new GenericIdentity ("bad"), null);
 716                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.CopyOnNewThread));
 717                         try {
 718                                 Thread.CurrentPrincipal = new GenericPrincipal (new GenericIdentity ("good"), null);
 719                                 t.Start ();
 720                                 t.Join ();
 721                         } catch {
 722                                 t.Abort ();
 723                         }
 724                 }
 725
 726                 int counter = 0;
 727
 728                 [Test]
 729                 public void TestSuspend ()
 730                 {
 731                         Thread t = new Thread (new ThreadStart (DoCount));
 732                         t.IsBackground = true;
 733                         t.Start ();
 734
 735                         CheckIsRunning ("t1", t);
 736
 737                         t.Suspend ();
 738                         WaitSuspended ("t2", t);
 739
 740                         CheckIsNotRunning ("t3", t);
 741
 742                         t.Resume ();
 743                         WaitResumed ("t4", t);
 744
 745                         CheckIsRunning ("t5", t);
 746
 747                         t.Abort ();
 748                         TestUtil.WaitForNotAlive (t, "wait13");
 749                         CheckIsNotRunning ("t6", t);
 750                 }
 751
 752                 [Test]
 753                 [Category("NotDotNet")] // On MS, ThreadStateException is thrown on Abort: "Thread is suspended; attempting to abort"
 754                 public void TestSuspendAbort ()
 755                 {
 756                         if (is_win32 && is_mono)
 757                                 Assert.Fail ("This test fails on Win32. The test should be fixed.");
 758
 759                         Thread t = new Thread (new ThreadStart (DoCount));
 760                         t.IsBackground = true;
 761                         t.Start ();
 762
 763                         CheckIsRunning ("t1", t);
 764
 765                         t.Suspend ();
 766                         WaitSuspended ("t2", t);
 767
 768                         CheckIsNotRunning ("t3", t);
 769
 770                         t.Abort ();
 771
 772                         int n=0;
 773                         while (t.IsAlive && n < 200) {
 774                                 Thread.Sleep (10);
 775                                 n++;
 776                         }
 777
 778                         Assert.IsTrue (n < 200, "Timeout while waiting for abort");
 779
 780                         CheckIsNotRunning ("t6", t);
 781                 }
 782
 783                 [Test]
 784                 public void Test_Interrupt ()
 785                 {
 786                         bool interruptedExceptionThrown = false;
 787                         ThreadPool.QueueUserWorkItem (Test_Interrupt_Worker, Thread.CurrentThread);
 788
 789                         try {
 790                                 try {
 791                                         Thread.Sleep (3000);
 792                                 } finally {
 793                                         try {
 794                                                 Thread.Sleep (0);
 795                                         } catch (ThreadInterruptedException) {
 796                                                 Assert.Fail ("ThreadInterruptedException thrown twice");
 797                                         }
 798                                 }
 799                         } catch (ThreadInterruptedException) {
 800                                 interruptedExceptionThrown = true;
 801                         }
 802
 803                         Assert.IsTrue (interruptedExceptionThrown, "ThreadInterruptedException expected.");
 804                 }
 805
 806                 [Test]
 807                 [ExpectedException (typeof (ArgumentNullException))]
 808                 public void TestQueueUserWorkItemNullCallback ()
 809                 {
 810                         ThreadPool.QueueUserWorkItem (null, null);
 811                 }
 812
 813                 private void Test_Interrupt_Worker (object o)
 814                 {
 815                         Thread t = o as Thread;
 816                         Thread.Sleep (100);
 817                         t.Interrupt ();
 818                 }
 819
 820                 [Test]
 821                 [Category ("NotDotNet")] // it crashes nunit.
 822                 public void Test_InterruptCurrentThread ()
 823                 {
 824                         bool interruptedExceptionThrown = false;
 825
 826                         Thread.CurrentThread.Interrupt ();
 827                         try {
 828                                 Thread.Sleep (0);
 829                                 Assert.Fail ();
 830                         } catch (ThreadInterruptedException) {
 831                         }
 832                 }
 833
 834                 void CheckIsRunning (string s, Thread t)
 835                 {
 836                         int c = counter;
 837                         Thread.Sleep (100);
 838                         Assert.IsTrue (counter > c, s);
 839                 }
 840
 841                 void CheckIsNotRunning (string s, Thread t)
 842                 {
 843                         int c = counter;
 844                         Thread.Sleep (100);
 845                         Assert.AreEqual (counter, c, s);
 846                 }
 847
 848                 void WaitSuspended (string s, Thread t)
 849                 {
 850                         int n=0;
 851                         ThreadState state = t.ThreadState;
 852                         while ((state & ThreadState.Suspended) == 0) {
 853                                 Assert.IsTrue ((state & ThreadState.SuspendRequested) != 0, s + ": expected SuspendRequested state");
 854                                 Thread.Sleep (10);
 855                                 n++;
 856                                 Assert.IsTrue (n < 100, s + ": failed to suspend");
 857                                 state = t.ThreadState;
 858                         }
 859                         Assert.IsTrue ((state & ThreadState.SuspendRequested) == 0, s + ": SuspendRequested state not expected");
 860                 }
 861
 862                 void WaitResumed (string s, Thread t)
 863                 {
 864                         int n=0;
 865                         while ((t.ThreadState & ThreadState.Suspended) != 0) {
 866                                 Thread.Sleep (10);
 867                                 n++;
 868                                 Assert.IsTrue (n < 100, s + ": failed to resume");
 869                         }
 870                 }
 871
 872                 public void DoCount ()
 873                 {
 874                         while (true) {
 875                                 counter++;
 876                                 Thread.Sleep (1);
 877                         }
 878                 }
 879         }
 880
 881         [TestFixture]
 882         public class ThreadStateTest {
 883                 void Start ()
 884                 {
 885                 }
 886
 887                 [Test] // bug #81720
 888                 public void IsBackGround ()
 889                 {
 890                         Thread t1 = new Thread (new ThreadStart (Start));
 891                         Assert.AreEqual (ThreadState.Unstarted, t1.ThreadState, "#A1");
 892                         Assert.IsFalse (t1.IsBackground, "#A2");
 893                         t1.Start ();
 894                         t1.Join ();
 895                         Assert.AreEqual (ThreadState.Stopped, t1.ThreadState, "#A3");
 896
 897                         try {
 898                                 bool isBackGround = t1.IsBackground;
 899                                 Assert.Fail ("#A4: " + isBackGround.ToString ());
 900                         } catch (ThreadStateException ex) {
 901                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#A5");
 902                                 Assert.IsNull (ex.InnerException, "#A6");
 903                                 Assert.IsNotNull (ex.Message, "#A7");
 904                         }
 905
 906                         Thread t2 = new Thread (new ThreadStart (Start));
 907                         Assert.AreEqual (ThreadState.Unstarted, t2.ThreadState, "#B1");
 908                         t2.IsBackground = true;
 909                         Assert.AreEqual (ThreadState.Unstarted | ThreadState.Background, t2.ThreadState, "#B2");
 910                         Assert.IsTrue (t2.IsBackground, "#B3");
 911                         t2.Start ();
 912                         t2.Join ();
 913                         Assert.AreEqual (ThreadState.Stopped, t2.ThreadState, "#B4");
 914
 915                         try {
 916                                 bool isBackGround = t2.IsBackground;
 917                                 Assert.Fail ("#B5: " + isBackGround.ToString ());
 918                         } catch (ThreadStateException ex) {
 919                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#B6");
 920                                 Assert.IsNull (ex.InnerException, "#B7");
 921                                 Assert.IsNotNull (ex.Message, "#B8");
 922                         }
 923                 }
 924         }
 925
 926         [TestFixture]
 927         [Serializable]
 928         public class ThreadTest_ManagedThreadId
 929         {
 930                 AppDomain ad1;
 931                 AppDomain ad2;
 932                 MBRO mbro = new MBRO ();
 933
 934                 class MBRO : MarshalByRefObject {
 935                         public int id_a1;
 936                         public int id_b1;
 937                         public int id_b2;
 938                         public string ad_a1;
 939                         public string ad_b1;
 940                         public string ad_b2;
 941                         public string message;
 942                 }
 943
 944                 [Test]
 945                 public void ManagedThreadId_AppDomains ()
 946                 {
 947                         AppDomain currentDomain = AppDomain.CurrentDomain;
 948                         ad1 = AppDomain.CreateDomain ("AppDomain 1", currentDomain.Evidence, currentDomain.SetupInformation);
 949                         ad2 = AppDomain.CreateDomain ("AppDomain 2", currentDomain.Evidence, currentDomain.SetupInformation);
 950
 951                         Thread a = new Thread (ThreadA);
 952                         Thread b = new Thread (ThreadB);
 953                         // execute on AppDomain 1 thread A
 954                         // execute on AppDomain 2 thread B
 955                         // execute on AppDomain 1 thread B - must have same ManagedThreadId as Ad 2 on thread B
 956                         a.Start ();
 957                         a.Join ();
 958                         b.Start ();
 959                         b.Join ();
 960
 961                         AppDomain.Unload (ad1);
 962                         AppDomain.Unload (ad2);
 963
 964                         if (mbro.message != null)
 965                                 Assert.Fail (mbro.message);
 966
 967                         // Console.WriteLine ("Done id_a1: {0} id_b1: {1} id_b2: {2} ad_a1: {3} ad_b1: {4} ad_b2: {5}", mbro.id_a1, mbro.id_b1, mbro.id_b2, mbro.ad_a1, mbro.ad_b1, mbro.ad_b2);
 968
 969                         Assert.AreEqual ("AppDomain 1", mbro.ad_a1, "Name #1");
 970                         Assert.AreEqual ("AppDomain 1", mbro.ad_b1, "Name #2");
 971                         Assert.AreEqual ("AppDomain 2", mbro.ad_b2, "Name #3");
 972
 973                         Assert.AreNotEqual (mbro.id_a1, mbro.id_b1, "Id #1");
 974                         Assert.AreNotEqual (mbro.id_a1, mbro.id_b2, "Id #2");
 975                         Assert.AreEqual (mbro.id_b1, mbro.id_b2, "Id #3");
 976
 977                         Assert.AreNotEqual (mbro.id_a1, Thread.CurrentThread.ManagedThreadId, "Id #4");
 978                         Assert.AreNotEqual (mbro.id_b1, Thread.CurrentThread.ManagedThreadId, "Id #5");
 979                         Assert.AreNotEqual (mbro.id_b2, Thread.CurrentThread.ManagedThreadId, "Id #6");
 980                         Assert.AreNotEqual (mbro.ad_a1, AppDomain.CurrentDomain.FriendlyName, "Name #4");
 981                         Assert.AreNotEqual (mbro.ad_b1, AppDomain.CurrentDomain.FriendlyName, "Name #5");
 982                         Assert.AreNotEqual (mbro.ad_b2, AppDomain.CurrentDomain.FriendlyName, "Name #6");
 983                 }
 984
 985                 void A1 ()
 986                 {
 987                         mbro.id_a1 = Thread.CurrentThread.ManagedThreadId;
 988                         mbro.ad_a1 = AppDomain.CurrentDomain.FriendlyName;
 989                 }
 990
 991                 void B2 ()
 992                 {
 993                         mbro.id_b2 = Thread.CurrentThread.ManagedThreadId;
 994                         mbro.ad_b2 = AppDomain.CurrentDomain.FriendlyName;
 995                 }
 996
 997                 void B1 ()
 998                 {
 999                         mbro.id_b1 = Thread.CurrentThread.ManagedThreadId;
1000                         mbro.ad_b1 = AppDomain.CurrentDomain.FriendlyName;
1001                 }
1002
1003                 void ThreadA (object obj)
1004                 {
1005                         // Console.WriteLine ("ThreadA");
1006                         try {
1007                                 ad1.DoCallBack (A1);
1008                         } catch (Exception ex) {
1009                                 mbro.message = string.Format ("ThreadA exception: {0}", ex);
1010                         }
1011                         // Console.WriteLine ("ThreadA Done");
1012                 }
1013
1014                 void ThreadB (object obj)
1015                 {
1016                         // Console.WriteLine ("ThreadB");
1017                         try {
1018                                 ad2.DoCallBack (B2);
1019                                 ad1.DoCallBack (B1);
1020                         } catch (Exception ex) {
1021                                 mbro.message = string.Format ("ThreadB exception: {0}", ex);
1022                         }
1023                         // Console.WriteLine ("ThreadB Done");
1024                 }
1025         }
1026
1027         [TestFixture]
1028         public class ThreadApartmentTest
1029         {
1030                 void Start ()
1031                 {
1032                 }
1033
1034                 [Test] // bug #81658
1035                 public void ApartmentState_StoppedThread ()
1036                 {
1037                         Thread t1 = new Thread (new ThreadStart (Start));
1038                         t1.Start ();
1039                         t1.Join ();
1040                         try {
1041                                 ApartmentState state = t1.ApartmentState;
1042                                 Assert.Fail ("#A1: " + state.ToString ());
1043                         } catch (ThreadStateException ex) {
1044                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#A2");
1045                                 Assert.IsNull (ex.InnerException, "#A3");
1046                                 Assert.IsNotNull (ex.Message, "#A4");
1047                         }
1048
1049                         Thread t2 = new Thread (new ThreadStart (Start));
1050                         t2.IsBackground = true;
1051                         t2.Start ();
1052                         t2.Join ();
1053                         try {
1054                                 ApartmentState state = t2.ApartmentState;
1055                                 Assert.Fail ("#B1: " + state.ToString ());
1056                         } catch (ThreadStateException ex) {
1057                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#B2");
1058                                 Assert.IsNull (ex.InnerException, "#B3");
1059                                 Assert.IsNotNull (ex.Message, "#B4");
1060                         }
1061                 }
1062
1063                 [Test]
1064                 public void ApartmentState_BackGround ()
1065                 {
1066                         Thread t1 = new Thread (new ThreadStart (Start));
1067                         t1.IsBackground = true;
1068                         Assert.AreEqual (ApartmentState.Unknown, t1.ApartmentState, "#1");
1069                         t1.ApartmentState = ApartmentState.STA;
1070                         Assert.AreEqual (ApartmentState.STA, t1.ApartmentState, "#2");
1071                 }
1072
1073                 [Test]
1074                 public void TestApartmentState ()
1075                 {
1076                         Thread t1 = new Thread (new ThreadStart (Start));
1077                         Thread t2 = new Thread (new ThreadStart (Start));
1078                         Thread t3 = new Thread (new ThreadStart (Start));
1079
1080                         Assert.AreEqual (ApartmentState.Unknown, t1.ApartmentState, "Thread1 Default");
1081                         Assert.AreEqual (ApartmentState.Unknown, t2.ApartmentState, "Thread2 Default");
1082                         Assert.AreEqual (ApartmentState.Unknown, t3.ApartmentState, "Thread3 Default");
1083
1084                         t1.ApartmentState = ApartmentState.STA;
1085                         Assert.AreEqual (ApartmentState.STA, t1.ApartmentState, "Thread1 Set Once");
1086                         t1.ApartmentState = ApartmentState.MTA;
1087                         Assert.AreEqual (ApartmentState.STA, t1.ApartmentState, "Thread1 Set Twice");
1088
1089                         t2.ApartmentState = ApartmentState.MTA;
1090                         Assert.AreEqual (ApartmentState.MTA, t2.ApartmentState, "Thread2 Set Once");
1091                         t2.ApartmentState = ApartmentState.STA;
1092                         Assert.AreEqual (ApartmentState.MTA, t2.ApartmentState, "Thread2 Set Twice");
1093
1094                         bool exception_occured = false;
1095                         try {
1096                                 t3.ApartmentState = ApartmentState.Unknown;
1097                         }
1098                         catch (Exception) {
1099                                 exception_occured = true;
1100                         }
1101                         Assert.AreEqual (ApartmentState.Unknown, t3.ApartmentState, "Thread3 Set Invalid");
1102 #if NET_2_0
1103                         Assert.IsFalse (exception_occured, "Thread3 Set Invalid Exception Occured");
1104 #else
1105                         Assert.IsTrue (exception_occured, "Thread3 Set Invalid Exception Occured");
1106 #endif
1107
1108                         t1.Start ();
1109                         exception_occured = false;
1110                         try {
1111                                 t1.ApartmentState = ApartmentState.STA;
1112                         }
1113                         catch (Exception) {
1114                                 exception_occured = true;
1115                         }
1116                         Assert.IsTrue (exception_occured, "Thread1 Started Invalid Exception Occured");
1117                 }
1118
1119                 [Test]
1120                 public void Volatile () {
1121                         double v3 = 55667;
1122                         Thread.VolatileWrite (ref v3, double.MaxValue);
1123                         Assert.AreEqual (v3, double.MaxValue);
1124
1125                         float v4 = 1;
1126                         Thread.VolatileWrite (ref v4, float.MaxValue);
1127                         Assert.AreEqual (v4, float.MaxValue);
1128                 }
1129
1130                 [Test]
1131                 public void SetNameTpThread () {
1132                         ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc));
1133                 }
1134
1135                 static void ThreadProc(Object stateInfo) {
1136                         Thread.CurrentThread.Name = "My Worker";
1137                 }
1138         }
1139
1140         public class TestUtil
1141         {
1142                 public static void WaitForNotAlive (Thread t, string s)
1143                 {
1144                         WhileAlive (t, true, s);
1145                 }
1146
1147                 public static void WaitForAlive (Thread t, string s)
1148                 {
1149                         WhileAlive (t, false, s);
1150                 }
1151
1152                 public static bool WaitForAliveOrStop (Thread t, string s)
1153                 {
1154                         return WhileAliveOrStop (t, false, s);
1155                 }
1156
1157                 public static void WhileAlive (Thread t, bool alive, string s)
1158                 {
1159                         DateTime ti = DateTime.Now;
1160                         while (t.IsAlive == alive) {
1161                                 if ((DateTime.Now - ti).TotalSeconds > 10) {
1162                                         if (alive) Assert.Fail ("Timeout while waiting for not alive state. " + s);
1163                                         else Assert.Fail ("Timeout while waiting for alive state. " + s);
1164                                 }
1165                         }
1166                 }
1167
1168                 public static bool WhileAliveOrStop (Thread t, bool alive, string s)
1169                 {
1170                         DateTime ti = DateTime.Now;
1171                         while (t.IsAlive == alive) {
1172                                 if (t.ThreadState == ThreadState.Stopped)
1173                                         return false;
1174
1175                                 if ((DateTime.Now - ti).TotalSeconds > 10) {
1176                                         if (alive) Assert.Fail ("Timeout while waiting for not alive state. " + s);
1177                                         else Assert.Fail ("Timeout while waiting for alive state. " + s);
1178                                 }
1179                         }
1180
1181                         return true;
1182                 }
1183         }
1184 }