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                 [Category ("NotDotNet")] // on MS, ThreadState is immediately Stopped after Abort
 481                 public void TestIsBackground2 ()
 482                 {
 483                         C2Test test1 = new C2Test();
 484                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 485                         TestThread.IsBackground = true;
 486                         try {
 487                                 TestThread.Start();
 488                         } finally {
 489                                 TestThread.Abort();
 490                         }
 491                         Assert.IsTrue (TestThread.IsBackground, "#52 Is Background Changed to Start ");
 492                 }
 493
 494                 [Test]
 495                 public void TestName()
 496                 {
 497                         if (is_win32 && is_mono)
 498                                 Assert.Fail ("This test fails on mono on Win32. Our runtime should be fixed.");
 499
 500                         C2Test test1 = new C2Test();
 501                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 502                         try {
 503                                 TestThread.Start();
 504                                 TestUtil.WaitForAlive (TestThread, "wait10");
 505                                 string name = TestThread.Name;
 506                                 Assert.IsNull (name, "#61 Name set when mustn't be set: ");
 507                                 string newname = "Testing....";
 508                                 TestThread.Name = newname;
 509                                 Assert.AreEqual (newname, TestThread.Name, "#62 Name not set when must be set: ");
 510                         } finally {
 511                                 TestThread.Abort();
 512                         }
 513                 }
 514
 515                 [Test]
 516                 public void Name ()
 517                 {
 518                         Thread t = new Thread (new ThreadStart (Name));
 519                         Assert.IsNull (t.Name, "Name-1");
 520                         t.Name = null;
 521                         Assert.IsNull (t.Name, "Name-2");
 522                 }
 523
 524                 [Test]
 525                 [ExpectedException (typeof (InvalidOperationException))]
 526                 public void ReName ()
 527                 {
 528                         Thread t = new Thread (new ThreadStart (ReName));
 529                         t.Name = "a";
 530                         t.Name = "b";
 531                 }
 532
 533                 [Test]
 534                 public void TestNestedThreads1()
 535                 {
 536                         C3Test test1 = new C3Test();
 537                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod1));
 538                         try {
 539                                 TestThread.Start();
 540                                 TestUtil.WaitForAlive (TestThread, "wait11");
 541                         } finally {
 542                                 TestThread.Abort();
 543                         }
 544                 }
 545
 546                 [Test]
 547                 public void TestNestedThreads2()
 548                 {
 549                         C4Test test1 = new C4Test();
 550                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod1));
 551                         try {
 552                                 TestThread.Start();
 553                         } finally {
 554                                 TestThread.Abort();
 555                         }
 556                 }
 557
 558                 [Test]
 559                 public void TestJoin1()
 560                 {
 561                         C1Test test1 = new C1Test();
 562                         C1Test test2 = new C1Test();
 563                         Thread thread1 = new Thread(new ThreadStart(test1.TestMethod));
 564                         Thread thread2 = new Thread(new ThreadStart(test1.TestMethod2));
 565                         try {
 566                                 thread1.Start();
 567                                 thread2.Start();
 568                                 thread2.Join();
 569                         } finally {
 570                                 thread1.Abort();
 571                                 thread2.Abort();
 572                         }
 573                 }
 574
 575                 [Test]
 576                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 577                 public void Join_Int32_Negative ()
 578                 {
 579                         // -1 is Timeout.Infinite
 580                         Thread.CurrentThread.Join (-2);
 581                 }
 582
 583                 [Test]
 584                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 585                 public void Join_TimeSpan_Negative ()
 586                 {
 587                         Thread.CurrentThread.Join (Negative);
 588                 }
 589
 590                 [Test]
 591                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 592                 public void Join_TimeSpan_TooLarge ()
 593                 {
 594                         Thread.CurrentThread.Join (TooLarge);
 595                 }
 596
 597                 [Test]
 598                 public void Join_TimeSpan_SmallNegative ()
 599                 {
 600                         Thread.CurrentThread.Join (SmallNegative);
 601                 }
 602
 603                 [Test]
 604                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 605                 public void Sleep_Int32_Negative ()
 606                 {
 607                         // -1 is Timeout.Infinite
 608                         Thread.Sleep (-2);
 609                 }
 610
 611                 [Test]
 612                 public void Sleep_TimeSpan_SmallNegative ()
 613                 {
 614                         Thread.Sleep (SmallNegative);
 615                 }
 616
 617                 [Test]
 618                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 619                 public void Sleep_TimeSpan_Negative ()
 620                 {
 621                         Thread.Sleep (Negative);
 622                 }
 623
 624                 [Test]
 625                 [ExpectedException (typeof (ArgumentOutOfRangeException))]
 626                 public void Sleep_TimeSpan_TooLarge ()
 627                 {
 628                         Thread.Sleep (TooLarge);
 629                 }
 630
 631                 [Test]
 632                 public void SpinWait ()
 633                 {
 634                         // no exception for negative numbers
 635                         Thread.SpinWait (Int32.MinValue);
 636                         Thread.SpinWait (0);
 637                 }
 638
 639                 [Test]
 640                 public void TestThreadState ()
 641                 {
 642                         if (is_win32 && is_mono)
 643                                 Assert.Fail ("This test fails on mono on Win32. Our runtime should be fixed.");
 644
 645                         //TODO: Test The rest of the possible transitions
 646                         C2Test test1 = new C2Test();
 647                         Thread TestThread = new Thread(new ThreadStart(test1.TestMethod));
 648                         Assert.AreEqual (ThreadState.Unstarted, TestThread.ThreadState, "#101 Wrong Thread State");
 649                         try {
 650                                 TestThread.Start();
 651                                 //while(!TestThread.IsAlive); //In the MS Documentation this is not necessary
 652                                                                                           //but in the MS SDK it is
 653                                 Assert.IsTrue (TestThread.ThreadState == ThreadState.Running || (TestThread.ThreadState & ThreadState.Unstarted) != 0,
 654                                         "#102 Wrong Thread State: " + TestThread.ThreadState.ToString ());
 655                         } finally {
 656                                 TestThread.Abort();
 657                         }
 658
 659                         TestUtil.WaitForNotAlive (TestThread, "wait12");
 660                         // Docs say state will be Stopped, but Aborted happens sometimes (?)
 661                         Assert.IsTrue ((ThreadState.Stopped & TestThread.ThreadState) != 0 || (ThreadState.Aborted & TestThread.ThreadState) != 0,
 662                                 "#103 Wrong Thread State: " + TestThread.ThreadState.ToString ());
 663                 }
 664
 665                 [Test]
 666                 [Ignore ("see comment below.")]
 667                 public void CurrentPrincipal_PrincipalPolicy_NoPrincipal ()
 668                 {
 669                         // note: switching from PrincipalPolicy won't work inside the same thread
 670                         // because as soon as a Principal object is created the Policy doesn't matter anymore
 671                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.NoPrincipal));
 672                         try {
 673                                 t.Start ();
 674                                 t.Join ();
 675                         } catch {
 676                                 t.Abort ();
 677                         }
 678                 }
 679
 680 #if !TARGET_JVM // AppDomain.SetPrincipalPolicy not supported for TARGET_JVM
 681                 [Test]
 682                 [Ignore ("see comment below.")]
 683                 public void CurrentPrincipal_PrincipalPolicy_UnauthenticatedPrincipal ()
 684                 {
 685                         // note: switching from PrincipalPolicy won't work inside the same thread
 686                         // because as soon as a Principal object is created the Policy doesn't matter anymore
 687                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.UnauthenticatedPrincipal));
 688                         try {
 689                                 t.Start ();
 690                                 t.Join ();
 691                         } catch {
 692                                 t.Abort ();
 693                         }
 694                 }
 695
 696                 [Test]
 697                 public void CurrentPrincipal_PrincipalPolicy_WindowsPrincipal ()
 698                 {
 699                         // note: switching from PrincipalPolicy won't work inside the same thread
 700                         // because as soon as a Principal object is created the Policy doesn't matter anymore
 701                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.WindowsPrincipal));
 702                         try {
 703                                 t.Start ();
 704                                 t.Join ();
 705                         } catch {
 706                                 t.Abort ();
 707                         }
 708                 }
 709 #endif // TARGET_JVM
 710
 711                 [Test]
 712                 public void IPrincipal_CopyOnNewThread ()
 713                 {
 714                         Thread.CurrentPrincipal = new GenericPrincipal (new GenericIdentity ("bad"), null);
 715                         Thread t = new Thread (new ThreadStart (ThreadedPrincipalTest.CopyOnNewThread));
 716                         try {
 717                                 Thread.CurrentPrincipal = new GenericPrincipal (new GenericIdentity ("good"), null);
 718                                 t.Start ();
 719                                 t.Join ();
 720                         } catch {
 721                                 t.Abort ();
 722                         }
 723                 }
 724
 725                 int counter = 0;
 726
 727                 [Test]
 728                 public void TestSuspend ()
 729                 {
 730                         Thread t = new Thread (new ThreadStart (DoCount));
 731                         t.IsBackground = true;
 732                         t.Start ();
 733
 734                         CheckIsRunning ("t1", t);
 735
 736                         t.Suspend ();
 737                         WaitSuspended ("t2", t);
 738
 739                         CheckIsNotRunning ("t3", t);
 740
 741                         t.Resume ();
 742                         WaitResumed ("t4", t);
 743
 744                         CheckIsRunning ("t5", t);
 745
 746                         t.Abort ();
 747                         TestUtil.WaitForNotAlive (t, "wait13");
 748                         CheckIsNotRunning ("t6", t);
 749                 }
 750
 751                 [Test]
 752                 [Category("NotDotNet")] // On MS, ThreadStateException is thrown on Abort: "Thread is suspended; attempting to abort"
 753                 public void TestSuspendAbort ()
 754                 {
 755                         if (is_win32 && is_mono)
 756                                 Assert.Fail ("This test fails on Win32. The test should be fixed.");
 757
 758                         Thread t = new Thread (new ThreadStart (DoCount));
 759                         t.IsBackground = true;
 760                         t.Start ();
 761
 762                         CheckIsRunning ("t1", t);
 763
 764                         t.Suspend ();
 765                         WaitSuspended ("t2", t);
 766
 767                         CheckIsNotRunning ("t3", t);
 768
 769                         t.Abort ();
 770
 771                         int n=0;
 772                         while (t.IsAlive && n < 200) {
 773                                 Thread.Sleep (10);
 774                                 n++;
 775                         }
 776
 777                         Assert.IsTrue (n < 200, "Timeout while waiting for abort");
 778
 779                         CheckIsNotRunning ("t6", t);
 780                 }
 781
 782                 [Test]
 783                 public void Test_Interrupt ()
 784                 {
 785                         bool interruptedExceptionThrown = false;
 786                         ThreadPool.QueueUserWorkItem (Test_Interrupt_Worker, Thread.CurrentThread);
 787
 788                         try {
 789                                 try {
 790                                         Thread.Sleep (3000);
 791                                 } finally {
 792                                         try {
 793                                                 Thread.Sleep (0);
 794                                         } catch (ThreadInterruptedException) {
 795                                                 Assert.Fail ("ThreadInterruptedException thrown twice");
 796                                         }
 797                                 }
 798                         } catch (ThreadInterruptedException) {
 799                                 interruptedExceptionThrown = true;
 800                         }
 801
 802                         Assert.IsTrue (interruptedExceptionThrown, "ThreadInterruptedException expected.");
 803                 }
 804
 805                 [Test]
 806                 [ExpectedException (typeof (ArgumentNullException))]
 807                 public void TestQueueUserWorkItemNullCallback ()
 808                 {
 809                         ThreadPool.QueueUserWorkItem (null, null);
 810                 }
 811
 812                 private void Test_Interrupt_Worker (object o)
 813                 {
 814                         Thread t = o as Thread;
 815                         Thread.Sleep (100);
 816                         t.Interrupt ();
 817                 }
 818
 819                 [Test]
 820                 [Category ("NotDotNet")] // it crashes nunit.
 821                 public void Test_InterruptCurrentThread ()
 822                 {
 823                         bool interruptedExceptionThrown = false;
 824
 825                         Thread.CurrentThread.Interrupt ();
 826                         try {
 827                                 Thread.Sleep (0);
 828                                 Assert.Fail ();
 829                         } catch (ThreadInterruptedException) {
 830                         }
 831                 }
 832
 833                 void CheckIsRunning (string s, Thread t)
 834                 {
 835                         int c = counter;
 836                         Thread.Sleep (100);
 837                         Assert.IsTrue (counter > c, s);
 838                 }
 839
 840                 void CheckIsNotRunning (string s, Thread t)
 841                 {
 842                         int c = counter;
 843                         Thread.Sleep (100);
 844                         Assert.AreEqual (counter, c, s);
 845                 }
 846
 847                 void WaitSuspended (string s, Thread t)
 848                 {
 849                         int n=0;
 850                         ThreadState state = t.ThreadState;
 851                         while ((state & ThreadState.Suspended) == 0) {
 852                                 Assert.IsTrue ((state & ThreadState.SuspendRequested) != 0, s + ": expected SuspendRequested state");
 853                                 Thread.Sleep (10);
 854                                 n++;
 855                                 Assert.IsTrue (n < 100, s + ": failed to suspend");
 856                                 state = t.ThreadState;
 857                         }
 858                         Assert.IsTrue ((state & ThreadState.SuspendRequested) == 0, s + ": SuspendRequested state not expected");
 859                 }
 860
 861                 void WaitResumed (string s, Thread t)
 862                 {
 863                         int n=0;
 864                         while ((t.ThreadState & ThreadState.Suspended) != 0) {
 865                                 Thread.Sleep (10);
 866                                 n++;
 867                                 Assert.IsTrue (n < 100, s + ": failed to resume");
 868                         }
 869                 }
 870
 871                 public void DoCount ()
 872                 {
 873                         while (true) {
 874                                 counter++;
 875                                 Thread.Sleep (1);
 876                         }
 877                 }
 878         }
 879
 880         [TestFixture]
 881         public class ThreadStateTest {
 882                 void Start ()
 883                 {
 884                 }
 885
 886                 [Test] // bug #81720
 887                 public void IsBackGround ()
 888                 {
 889                         Thread t1 = new Thread (new ThreadStart (Start));
 890                         Assert.AreEqual (ThreadState.Unstarted, t1.ThreadState, "#A1");
 891                         Assert.IsFalse (t1.IsBackground, "#A2");
 892                         t1.Start ();
 893                         t1.Join ();
 894                         Assert.AreEqual (ThreadState.Stopped, t1.ThreadState, "#A3");
 895
 896                         try {
 897                                 bool isBackGround = t1.IsBackground;
 898                                 Assert.Fail ("#A4: " + isBackGround.ToString ());
 899                         } catch (ThreadStateException ex) {
 900                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#A5");
 901                                 Assert.IsNull (ex.InnerException, "#A6");
 902                                 Assert.IsNotNull (ex.Message, "#A7");
 903                         }
 904
 905                         Thread t2 = new Thread (new ThreadStart (Start));
 906                         Assert.AreEqual (ThreadState.Unstarted, t2.ThreadState, "#B1");
 907                         t2.IsBackground = true;
 908                         Assert.AreEqual (ThreadState.Unstarted | ThreadState.Background, t2.ThreadState, "#B2");
 909                         Assert.IsTrue (t2.IsBackground, "#B3");
 910                         t2.Start ();
 911                         t2.Join ();
 912                         Assert.AreEqual (ThreadState.Stopped, t2.ThreadState, "#B4");
 913
 914                         try {
 915                                 bool isBackGround = t2.IsBackground;
 916                                 Assert.Fail ("#B5: " + isBackGround.ToString ());
 917                         } catch (ThreadStateException ex) {
 918                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#B6");
 919                                 Assert.IsNull (ex.InnerException, "#B7");
 920                                 Assert.IsNotNull (ex.Message, "#B8");
 921                         }
 922                 }
 923         }
 924
 925         [TestFixture]
 926         [Serializable]
 927         public class ThreadTest_ManagedThreadId
 928         {
 929                 AppDomain ad1;
 930                 AppDomain ad2;
 931                 MBRO mbro = new MBRO ();
 932
 933                 class MBRO : MarshalByRefObject {
 934                         public int id_a1;
 935                         public int id_b1;
 936                         public int id_b2;
 937                         public string ad_a1;
 938                         public string ad_b1;
 939                         public string ad_b2;
 940                         public string message;
 941                 }
 942
 943                 [Test]
 944                 public void ManagedThreadId_AppDomains ()
 945                 {
 946                         AppDomain currentDomain = AppDomain.CurrentDomain;
 947                         ad1 = AppDomain.CreateDomain ("AppDomain 1", currentDomain.Evidence, currentDomain.SetupInformation);
 948                         ad2 = AppDomain.CreateDomain ("AppDomain 2", currentDomain.Evidence, currentDomain.SetupInformation);
 949
 950                         Thread a = new Thread (ThreadA);
 951                         Thread b = new Thread (ThreadB);
 952                         // execute on AppDomain 1 thread A
 953                         // execute on AppDomain 2 thread B
 954                         // execute on AppDomain 1 thread B - must have same ManagedThreadId as Ad 2 on thread B
 955                         a.Start ();
 956                         a.Join ();
 957                         b.Start ();
 958                         b.Join ();
 959
 960                         AppDomain.Unload (ad1);
 961                         AppDomain.Unload (ad2);
 962
 963                         if (mbro.message != null)
 964                                 Assert.Fail (mbro.message);
 965
 966                         // 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);
 967
 968                         Assert.AreEqual ("AppDomain 1", mbro.ad_a1, "Name #1");
 969                         Assert.AreEqual ("AppDomain 1", mbro.ad_b1, "Name #2");
 970                         Assert.AreEqual ("AppDomain 2", mbro.ad_b2, "Name #3");
 971
 972                         Assert.AreNotEqual (mbro.id_a1, mbro.id_b1, "Id #1");
 973                         Assert.AreNotEqual (mbro.id_a1, mbro.id_b2, "Id #2");
 974                         Assert.AreEqual (mbro.id_b1, mbro.id_b2, "Id #3");
 975
 976                         Assert.AreNotEqual (mbro.id_a1, Thread.CurrentThread.ManagedThreadId, "Id #4");
 977                         Assert.AreNotEqual (mbro.id_b1, Thread.CurrentThread.ManagedThreadId, "Id #5");
 978                         Assert.AreNotEqual (mbro.id_b2, Thread.CurrentThread.ManagedThreadId, "Id #6");
 979                         Assert.AreNotEqual (mbro.ad_a1, AppDomain.CurrentDomain.FriendlyName, "Name #4");
 980                         Assert.AreNotEqual (mbro.ad_b1, AppDomain.CurrentDomain.FriendlyName, "Name #5");
 981                         Assert.AreNotEqual (mbro.ad_b2, AppDomain.CurrentDomain.FriendlyName, "Name #6");
 982                 }
 983
 984                 void A1 ()
 985                 {
 986                         mbro.id_a1 = Thread.CurrentThread.ManagedThreadId;
 987                         mbro.ad_a1 = AppDomain.CurrentDomain.FriendlyName;
 988                 }
 989
 990                 void B2 ()
 991                 {
 992                         mbro.id_b2 = Thread.CurrentThread.ManagedThreadId;
 993                         mbro.ad_b2 = AppDomain.CurrentDomain.FriendlyName;
 994                 }
 995
 996                 void B1 ()
 997                 {
 998                         mbro.id_b1 = Thread.CurrentThread.ManagedThreadId;
 999                         mbro.ad_b1 = AppDomain.CurrentDomain.FriendlyName;
1000                 }
1001
1002                 void ThreadA (object obj)
1003                 {
1004                         // Console.WriteLine ("ThreadA");
1005                         try {
1006                                 ad1.DoCallBack (A1);
1007                         } catch (Exception ex) {
1008                                 mbro.message = string.Format ("ThreadA exception: {0}", ex);
1009                         }
1010                         // Console.WriteLine ("ThreadA Done");
1011                 }
1012
1013                 void ThreadB (object obj)
1014                 {
1015                         // Console.WriteLine ("ThreadB");
1016                         try {
1017                                 ad2.DoCallBack (B2);
1018                                 ad1.DoCallBack (B1);
1019                         } catch (Exception ex) {
1020                                 mbro.message = string.Format ("ThreadB exception: {0}", ex);
1021                         }
1022                         // Console.WriteLine ("ThreadB Done");
1023                 }
1024         }
1025
1026         [TestFixture]
1027         public class ThreadApartmentTest
1028         {
1029                 void Start ()
1030                 {
1031                 }
1032
1033                 [Test] // bug #81658
1034                 public void ApartmentState_StoppedThread ()
1035                 {
1036                         Thread t1 = new Thread (new ThreadStart (Start));
1037                         t1.Start ();
1038                         t1.Join ();
1039                         try {
1040                                 ApartmentState state = t1.ApartmentState;
1041                                 Assert.Fail ("#A1: " + state.ToString ());
1042                         } catch (ThreadStateException ex) {
1043                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#A2");
1044                                 Assert.IsNull (ex.InnerException, "#A3");
1045                                 Assert.IsNotNull (ex.Message, "#A4");
1046                         }
1047
1048                         Thread t2 = new Thread (new ThreadStart (Start));
1049                         t2.IsBackground = true;
1050                         t2.Start ();
1051                         t2.Join ();
1052                         try {
1053                                 ApartmentState state = t2.ApartmentState;
1054                                 Assert.Fail ("#B1: " + state.ToString ());
1055                         } catch (ThreadStateException ex) {
1056                                 Assert.AreEqual (typeof (ThreadStateException), ex.GetType (), "#B2");
1057                                 Assert.IsNull (ex.InnerException, "#B3");
1058                                 Assert.IsNotNull (ex.Message, "#B4");
1059                         }
1060                 }
1061
1062                 [Test]
1063                 public void ApartmentState_BackGround ()
1064                 {
1065                         Thread t1 = new Thread (new ThreadStart (Start));
1066                         t1.IsBackground = true;
1067                         Assert.AreEqual (ApartmentState.Unknown, t1.ApartmentState, "#1");
1068                         t1.ApartmentState = ApartmentState.STA;
1069                         Assert.AreEqual (ApartmentState.STA, t1.ApartmentState, "#2");
1070                 }
1071
1072                 [Test]
1073                 public void TestApartmentState ()
1074                 {
1075                         Thread t1 = new Thread (new ThreadStart (Start));
1076                         Thread t2 = new Thread (new ThreadStart (Start));
1077                         Thread t3 = new Thread (new ThreadStart (Start));
1078
1079                         Assert.AreEqual (ApartmentState.Unknown, t1.ApartmentState, "Thread1 Default");
1080                         Assert.AreEqual (ApartmentState.Unknown, t2.ApartmentState, "Thread2 Default");
1081                         Assert.AreEqual (ApartmentState.Unknown, t3.ApartmentState, "Thread3 Default");
1082
1083                         t1.ApartmentState = ApartmentState.STA;
1084                         Assert.AreEqual (ApartmentState.STA, t1.ApartmentState, "Thread1 Set Once");
1085                         t1.ApartmentState = ApartmentState.MTA;
1086                         Assert.AreEqual (ApartmentState.STA, t1.ApartmentState, "Thread1 Set Twice");
1087
1088                         t2.ApartmentState = ApartmentState.MTA;
1089                         Assert.AreEqual (ApartmentState.MTA, t2.ApartmentState, "Thread2 Set Once");
1090                         t2.ApartmentState = ApartmentState.STA;
1091                         Assert.AreEqual (ApartmentState.MTA, t2.ApartmentState, "Thread2 Set Twice");
1092
1093                         bool exception_occured = false;
1094                         try {
1095                                 t3.ApartmentState = ApartmentState.Unknown;
1096                         }
1097                         catch (Exception) {
1098                                 exception_occured = true;
1099                         }
1100                         Assert.AreEqual (ApartmentState.Unknown, t3.ApartmentState, "Thread3 Set Invalid");
1101 #if NET_2_0
1102                         Assert.IsFalse (exception_occured, "Thread3 Set Invalid Exception Occured");
1103 #else
1104                         Assert.IsTrue (exception_occured, "Thread3 Set Invalid Exception Occured");
1105 #endif
1106
1107                         t1.Start ();
1108                         exception_occured = false;
1109                         try {
1110                                 t1.ApartmentState = ApartmentState.STA;
1111                         }
1112                         catch (Exception) {
1113                                 exception_occured = true;
1114                         }
1115                         Assert.IsTrue (exception_occured, "Thread1 Started Invalid Exception Occured");
1116                 }
1117
1118                 [Test]
1119                 public void Volatile () {
1120                         double v3 = 55667;
1121                         Thread.VolatileWrite (ref v3, double.MaxValue);
1122                         Assert.AreEqual (v3, double.MaxValue);
1123
1124                         float v4 = 1;
1125                         Thread.VolatileWrite (ref v4, float.MaxValue);
1126                         Assert.AreEqual (v4, float.MaxValue);
1127                 }
1128
1129                 [Test]
1130                 public void SetNameTpThread () {
1131                         ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc));
1132                 }
1133
1134                 static void ThreadProc(Object stateInfo) {
1135                         Thread.CurrentThread.Name = "My Worker";
1136                 }
1137         }
1138
1139         public class TestUtil
1140         {
1141                 public static void WaitForNotAlive (Thread t, string s)
1142                 {
1143                         WhileAlive (t, true, s);
1144                 }
1145
1146                 public static void WaitForAlive (Thread t, string s)
1147                 {
1148                         WhileAlive (t, false, s);
1149                 }
1150
1151                 public static bool WaitForAliveOrStop (Thread t, string s)
1152                 {
1153                         return WhileAliveOrStop (t, false, s);
1154                 }
1155
1156                 public static void WhileAlive (Thread t, bool alive, string s)
1157                 {
1158                         DateTime ti = DateTime.Now;
1159                         while (t.IsAlive == alive) {
1160                                 if ((DateTime.Now - ti).TotalSeconds > 10) {
1161                                         if (alive) Assert.Fail ("Timeout while waiting for not alive state. " + s);
1162                                         else Assert.Fail ("Timeout while waiting for alive state. " + s);
1163                                 }
1164                         }
1165                 }
1166
1167                 public static bool WhileAliveOrStop (Thread t, bool alive, string s)
1168                 {
1169                         DateTime ti = DateTime.Now;
1170                         while (t.IsAlive == alive) {
1171                                 if (t.ThreadState == ThreadState.Stopped)
1172                                         return false;
1173
1174                                 if ((DateTime.Now - ti).TotalSeconds > 10) {
1175                                         if (alive) Assert.Fail ("Timeout while waiting for not alive state. " + s);
1176                                         else Assert.Fail ("Timeout while waiting for alive state. " + s);
1177                                 }
1178                         }
1179
1180                         return true;
1181                 }
1182         }
1183 }