ReaderWriterLockSlimTest.cs 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766
  1. //
  2. // ReaderWriterLockSlimTest.cs
  3. //
  4. // Authors:
  5. // Marek Safar ([email protected])
  6. //
  7. // Copyright (C) 2009 Novell, Inc (http://www.novell.com)
  8. //
  9. // Permission is hereby granted, free of charge, to any person obtaining
  10. // a copy of this software and associated documentation files (the
  11. // "Software"), to deal in the Software without restriction, including
  12. // without limitation the rights to use, copy, modify, merge, publish,
  13. // distribute, sublicense, and/or sell copies of the Software, and to
  14. // permit persons to whom the Software is furnished to do so, subject to
  15. // the following conditions:
  16. //
  17. // The above copyright notice and this permission notice shall be
  18. // included in all copies or substantial portions of the Software.
  19. //
  20. // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  21. // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  22. // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  23. // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  24. // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  25. // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  26. // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  27. //
  28. using System;
  29. using NUnit.Framework;
  30. using System.Threading;
  31. using System.Linq;
  32. using System.Threading.Tasks;
  33. namespace MonoTests.System.Threading
  34. {
  35. [TestFixture]
  36. public class ReaderWriterLockSlimTests
  37. {
  38. [Test]
  39. public void DefaultValues ()
  40. {
  41. var v = new ReaderWriterLockSlim ();
  42. Assert.AreEqual (0, v.CurrentReadCount, "1");
  43. Assert.AreEqual (false, v.IsReadLockHeld, "2");
  44. Assert.AreEqual (false, v.IsUpgradeableReadLockHeld, "3");
  45. Assert.AreEqual (false, v.IsWriteLockHeld, "4");
  46. Assert.AreEqual (LockRecursionPolicy.NoRecursion, v.RecursionPolicy, "5");
  47. Assert.AreEqual (0, v.RecursiveReadCount, "6");
  48. Assert.AreEqual (0, v.RecursiveUpgradeCount, "7");
  49. Assert.AreEqual (0, v.RecursiveWriteCount, "8");
  50. Assert.AreEqual (0, v.WaitingReadCount, "9");
  51. Assert.AreEqual (0, v.WaitingUpgradeCount, "10");
  52. Assert.AreEqual (0, v.WaitingWriteCount, "11");
  53. }
  54. [Test]
  55. public void Dispose_Errors ()
  56. {
  57. var v = new ReaderWriterLockSlim ();
  58. v.Dispose ();
  59. try {
  60. v.EnterUpgradeableReadLock ();
  61. Assert.Fail ("1");
  62. } catch (ObjectDisposedException) {
  63. }
  64. try {
  65. v.EnterReadLock ();
  66. Assert.Fail ("2");
  67. } catch (ObjectDisposedException) {
  68. }
  69. try {
  70. v.EnterWriteLock ();
  71. Assert.Fail ("3");
  72. } catch (ObjectDisposedException) {
  73. }
  74. }
  75. [Test]
  76. public void Dispose_WithReadLock ()
  77. {
  78. var rwl = new ReaderWriterLockSlim ();
  79. rwl.EnterReadLock ();
  80. try {
  81. rwl.Dispose ();
  82. Assert.Fail ("1");
  83. } catch (SynchronizationLockException) {
  84. }
  85. }
  86. [Test]
  87. public void Dispose_WithWriteLock ()
  88. {
  89. var rwl = new ReaderWriterLockSlim ();
  90. rwl.EnterWriteLock ();
  91. try {
  92. rwl.Dispose ();
  93. Assert.Fail ("1");
  94. } catch (SynchronizationLockException) {
  95. }
  96. }
  97. [Test]
  98. public void Dispose_UpgradeableReadLock ()
  99. {
  100. var rwl = new ReaderWriterLockSlim ();
  101. rwl.EnterUpgradeableReadLock ();
  102. try {
  103. rwl.Dispose ();
  104. Assert.Fail ("1");
  105. } catch (SynchronizationLockException) {
  106. }
  107. }
  108. [Test]
  109. public void TryEnterReadLock_OutOfRange ()
  110. {
  111. var v = new ReaderWriterLockSlim ();
  112. try {
  113. v.TryEnterReadLock (-2);
  114. Assert.Fail ("1");
  115. } catch (ArgumentOutOfRangeException) {
  116. }
  117. try {
  118. v.TryEnterReadLock (TimeSpan.MaxValue);
  119. Assert.Fail ("2");
  120. } catch (ArgumentOutOfRangeException) {
  121. }
  122. try {
  123. v.TryEnterReadLock (TimeSpan.MinValue);
  124. Assert.Fail ("3");
  125. } catch (ArgumentOutOfRangeException) {
  126. }
  127. }
  128. [Test]
  129. public void TryEnterUpgradeableReadLock_OutOfRange ()
  130. {
  131. var v = new ReaderWriterLockSlim ();
  132. try {
  133. v.TryEnterUpgradeableReadLock (-2);
  134. Assert.Fail ("1");
  135. } catch (ArgumentOutOfRangeException) {
  136. }
  137. try {
  138. v.TryEnterUpgradeableReadLock (TimeSpan.MaxValue);
  139. Assert.Fail ("2");
  140. } catch (ArgumentOutOfRangeException) {
  141. }
  142. try {
  143. v.TryEnterUpgradeableReadLock (TimeSpan.MinValue);
  144. Assert.Fail ("3");
  145. } catch (ArgumentOutOfRangeException) {
  146. }
  147. }
  148. [Test]
  149. public void TryEnterWriteLock_OutOfRange ()
  150. {
  151. var v = new ReaderWriterLockSlim ();
  152. try {
  153. v.TryEnterWriteLock (-2);
  154. Assert.Fail ("1");
  155. } catch (ArgumentOutOfRangeException) {
  156. }
  157. try {
  158. v.TryEnterWriteLock (TimeSpan.MaxValue);
  159. Assert.Fail ("2");
  160. } catch (ArgumentOutOfRangeException) {
  161. }
  162. try {
  163. v.TryEnterWriteLock (TimeSpan.MinValue);
  164. Assert.Fail ("3");
  165. } catch (ArgumentOutOfRangeException) {
  166. }
  167. }
  168. [Test, ExpectedException (typeof (SynchronizationLockException))]
  169. public void ExitReadLock ()
  170. {
  171. var v = new ReaderWriterLockSlim ();
  172. v.ExitReadLock ();
  173. }
  174. [Test, ExpectedException (typeof (SynchronizationLockException))]
  175. public void ExitWriteLock ()
  176. {
  177. var v = new ReaderWriterLockSlim ();
  178. v.ExitWriteLock ();
  179. }
  180. [Test]
  181. public void EnterReadLock_NoRecursionError ()
  182. {
  183. var v = new ReaderWriterLockSlim ();
  184. v.EnterReadLock ();
  185. Assert.AreEqual (1, v.RecursiveReadCount);
  186. try {
  187. v.EnterReadLock ();
  188. Assert.Fail ("1");
  189. } catch (LockRecursionException) {
  190. }
  191. try {
  192. v.EnterWriteLock ();
  193. Assert.Fail ("2");
  194. } catch (LockRecursionException) {
  195. }
  196. }
  197. [Test]
  198. public void EnterReadLock ()
  199. {
  200. var v = new ReaderWriterLockSlim ();
  201. v.EnterReadLock ();
  202. Assert.IsTrue (v.IsReadLockHeld, "A");
  203. Assert.AreEqual (0, v.RecursiveWriteCount, "A1");
  204. Assert.AreEqual (1, v.RecursiveReadCount, "A2");
  205. Assert.AreEqual (0, v.RecursiveUpgradeCount, "A3");
  206. Assert.AreEqual (0, v.WaitingReadCount, "A4");
  207. Assert.AreEqual (0, v.WaitingUpgradeCount, "A5");
  208. Assert.AreEqual (0, v.WaitingWriteCount, "A6");
  209. v.ExitReadLock ();
  210. v.EnterReadLock ();
  211. Assert.IsTrue (v.IsReadLockHeld, "B");
  212. Assert.AreEqual (0, v.RecursiveWriteCount, "B1");
  213. Assert.AreEqual (1, v.RecursiveReadCount, "B2");
  214. Assert.AreEqual (0, v.RecursiveUpgradeCount, "B3");
  215. Assert.AreEqual (0, v.WaitingReadCount, "B4");
  216. Assert.AreEqual (0, v.WaitingUpgradeCount, "B5");
  217. Assert.AreEqual (0, v.WaitingWriteCount, "B6");
  218. v.ExitReadLock ();
  219. }
  220. [Test]
  221. public void EnterWriteLock_NoRecursionError ()
  222. {
  223. var v = new ReaderWriterLockSlim ();
  224. v.EnterWriteLock ();
  225. Assert.AreEqual (1, v.RecursiveWriteCount);
  226. try {
  227. v.EnterWriteLock ();
  228. Assert.Fail ("1");
  229. } catch (LockRecursionException) {
  230. }
  231. try {
  232. v.EnterReadLock ();
  233. Assert.Fail ("2");
  234. } catch (LockRecursionException) {
  235. }
  236. }
  237. [Test]
  238. public void EnterWriteLock ()
  239. {
  240. var v = new ReaderWriterLockSlim ();
  241. v.EnterWriteLock ();
  242. Assert.IsTrue (v.IsWriteLockHeld, "A");
  243. Assert.AreEqual (1, v.RecursiveWriteCount, "A1");
  244. Assert.AreEqual (0, v.RecursiveReadCount, "A2");
  245. Assert.AreEqual (0, v.RecursiveUpgradeCount, "A3");
  246. Assert.AreEqual (0, v.WaitingReadCount, "A4");
  247. Assert.AreEqual (0, v.WaitingUpgradeCount, "A5");
  248. Assert.AreEqual (0, v.WaitingWriteCount, "A6");
  249. v.ExitWriteLock ();
  250. v.EnterWriteLock ();
  251. Assert.IsTrue (v.IsWriteLockHeld, "B");
  252. Assert.AreEqual (1, v.RecursiveWriteCount, "B1");
  253. Assert.AreEqual (0, v.RecursiveReadCount, "B2");
  254. Assert.AreEqual (0, v.RecursiveUpgradeCount, "B3");
  255. Assert.AreEqual (0, v.WaitingReadCount, "B4");
  256. Assert.AreEqual (0, v.WaitingUpgradeCount, "B5");
  257. Assert.AreEqual (0, v.WaitingWriteCount, "B6");
  258. v.ExitWriteLock ();
  259. }
  260. [Test]
  261. public void EnterUpgradeableReadLock_NoRecursionError ()
  262. {
  263. var v = new ReaderWriterLockSlim ();
  264. v.EnterUpgradeableReadLock ();
  265. Assert.AreEqual (1, v.RecursiveUpgradeCount);
  266. try {
  267. v.EnterUpgradeableReadLock ();
  268. Assert.Fail ("2");
  269. } catch (LockRecursionException) {
  270. }
  271. }
  272. [Test]
  273. public void EnterUpgradeableReadLock ()
  274. {
  275. var v = new ReaderWriterLockSlim ();
  276. v.EnterUpgradeableReadLock ();
  277. Assert.IsTrue (v.IsUpgradeableReadLockHeld, "A");
  278. Assert.AreEqual (0, v.RecursiveWriteCount, "A1");
  279. Assert.AreEqual (0, v.RecursiveReadCount, "A2");
  280. Assert.AreEqual (1, v.RecursiveUpgradeCount, "A3");
  281. Assert.AreEqual (0, v.WaitingReadCount, "A4");
  282. Assert.AreEqual (0, v.WaitingUpgradeCount, "A5");
  283. Assert.AreEqual (0, v.WaitingWriteCount, "A6");
  284. v.ExitUpgradeableReadLock ();
  285. v.EnterUpgradeableReadLock ();
  286. Assert.IsTrue (v.IsUpgradeableReadLockHeld, "B");
  287. Assert.AreEqual (0, v.RecursiveWriteCount, "B1");
  288. Assert.AreEqual (0, v.RecursiveReadCount, "B2");
  289. Assert.AreEqual (1, v.RecursiveUpgradeCount, "B3");
  290. Assert.AreEqual (0, v.WaitingReadCount, "B4");
  291. Assert.AreEqual (0, v.WaitingUpgradeCount, "B5");
  292. Assert.AreEqual (0, v.WaitingWriteCount, "B6");
  293. v.EnterReadLock ();
  294. v.ExitUpgradeableReadLock ();
  295. Assert.IsTrue (v.IsReadLockHeld, "C");
  296. Assert.AreEqual (0, v.RecursiveWriteCount, "C1");
  297. Assert.AreEqual (1, v.RecursiveReadCount, "C2");
  298. Assert.AreEqual (0, v.RecursiveUpgradeCount, "C3");
  299. Assert.AreEqual (0, v.WaitingReadCount, "C4");
  300. Assert.AreEqual (0, v.WaitingUpgradeCount, "C5");
  301. Assert.AreEqual (0, v.WaitingWriteCount, "C6");
  302. v.ExitReadLock ();
  303. }
  304. [Test]
  305. public void EnterReadLock_MultiRead ()
  306. {
  307. var v = new ReaderWriterLockSlim ();
  308. int local = 10;
  309. var r = from i in Enumerable.Range (1, 30) select new Thread (() => {
  310. // Just to cause some contention
  311. Thread.Sleep (100);
  312. v.EnterReadLock ();
  313. Assert.AreEqual (10, local);
  314. });
  315. var threads = r.ToList ();
  316. foreach (var t in threads) {
  317. t.Start ();
  318. }
  319. foreach (var t in threads) {
  320. // Console.WriteLine (t.ThreadState);
  321. t.Join ();
  322. }
  323. }
  324. [Test]
  325. public void TryEnterWriteLock_WhileReading ()
  326. {
  327. var v = new ReaderWriterLockSlim ();
  328. AutoResetEvent ev = new AutoResetEvent (false);
  329. AutoResetEvent ev2 = new AutoResetEvent (false);
  330. Thread t1 = new Thread (() => {
  331. v.EnterReadLock ();
  332. ev2.Set ();
  333. ev.WaitOne ();
  334. v.ExitReadLock ();
  335. });
  336. t1.Start ();
  337. ev2.WaitOne ();
  338. Assert.IsFalse (v.TryEnterWriteLock (100));
  339. ev.Set ();
  340. t1.Join ();
  341. Assert.IsTrue (v.TryEnterWriteLock (100));
  342. }
  343. [Test]
  344. public void EnterWriteLock_MultiRead ()
  345. {
  346. var v = new ReaderWriterLockSlim ();
  347. int local = 10;
  348. int ready_count = 0;
  349. int entered_count = 0;
  350. const int thread_count = 10;
  351. var r = from i in Enumerable.Range (1, thread_count) select new Thread (() => {
  352. Interlocked.Increment (ref ready_count);
  353. v.EnterReadLock ();
  354. Interlocked.Increment (ref entered_count);
  355. Assert.AreEqual (11, local);
  356. });
  357. v.EnterWriteLock ();
  358. var threads = r.ToList ();
  359. foreach (var t in threads) {
  360. t.Start ();
  361. }
  362. while (ready_count != thread_count)
  363. Thread.Sleep (10);
  364. /* Extra up to 2s of sleep to ensure all threads got the chance to enter the lock */
  365. for (int i = 0; i < 200 && v.WaitingReadCount != thread_count; ++i)
  366. Thread.Sleep (10);
  367. local = 11;
  368. Assert.AreEqual (0, v.WaitingWriteCount, "in waiting write");
  369. Assert.AreEqual (thread_count, v.WaitingReadCount, "in waiting read");
  370. Assert.AreEqual (0, v.WaitingUpgradeCount, "in waiting upgrade");
  371. v.ExitWriteLock ();
  372. foreach (var t in threads) {
  373. // Console.WriteLine (t.ThreadState);
  374. t.Join ();
  375. }
  376. }
  377. [Test]
  378. public void EnterWriteLock_After_ExitUpgradeableReadLock ()
  379. {
  380. var v = new ReaderWriterLockSlim ();
  381. v.EnterUpgradeableReadLock ();
  382. Assert.IsTrue (v.TryEnterWriteLock (100));
  383. v.ExitWriteLock ();
  384. v.ExitUpgradeableReadLock ();
  385. Assert.IsTrue (v.TryEnterWriteLock (100));
  386. v.ExitWriteLock ();
  387. }
  388. [Test]
  389. public void EnterWriteLockWhileInUpgradeAndOtherWaiting ()
  390. {
  391. var v = new ReaderWriterLockSlim ();
  392. var task2 = new Task(() => {
  393. v.EnterWriteLock();
  394. v.ExitWriteLock();
  395. });
  396. var task1 = new Task(() =>
  397. {
  398. v.EnterUpgradeableReadLock ();
  399. task2.Start ();
  400. Thread.Sleep (100);
  401. v.EnterWriteLock ();
  402. v.ExitWriteLock ();
  403. v.ExitUpgradeableReadLock ();
  404. });
  405. task1.Start ();
  406. Assert.IsTrue (task1.Wait (500));
  407. }
  408. [Test]
  409. public void RecursiveReadLockTest ()
  410. {
  411. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  412. Assert.IsTrue (v.TryEnterReadLock (100), "#1");
  413. Assert.IsTrue (v.TryEnterReadLock (100), "#2");
  414. Assert.IsTrue (v.TryEnterReadLock (100), "#3");
  415. Assert.AreEqual (3, v.RecursiveReadCount);
  416. }
  417. [Test]
  418. public void RecursiveReadPlusWriteLockTest ()
  419. {
  420. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  421. try {
  422. v.EnterReadLock ();
  423. v.EnterWriteLock ();
  424. Assert.Fail ("1");
  425. } catch (LockRecursionException ex) {
  426. Assert.IsNotNull (ex, "#1");
  427. }
  428. }
  429. [Test]
  430. public void RecursiveReadPlusUpgradeableLockTest ()
  431. {
  432. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  433. try {
  434. v.EnterReadLock ();
  435. v.EnterUpgradeableReadLock ();
  436. Assert.Fail ("1");
  437. } catch (LockRecursionException ex) {
  438. Assert.IsNotNull (ex, "#1");
  439. }
  440. }
  441. [Test]
  442. public void RecursiveWriteLockTest ()
  443. {
  444. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  445. Assert.IsTrue (v.TryEnterWriteLock (100), "#1");
  446. Assert.IsTrue (v.TryEnterWriteLock (100), "#2");
  447. Assert.IsTrue (v.TryEnterWriteLock (100), "#3");
  448. Assert.AreEqual (3, v.RecursiveWriteCount);
  449. }
  450. [Test]
  451. public void RecursiveWritePlusReadLockTest ()
  452. {
  453. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  454. Assert.IsTrue (v.TryEnterWriteLock (100), "#1");
  455. Assert.AreEqual (1, v.RecursiveWriteCount, "1b");
  456. Assert.AreEqual (0, v.RecursiveReadCount, "1c");
  457. Assert.IsTrue (v.TryEnterReadLock (100), "#2");
  458. Assert.AreEqual (1, v.RecursiveWriteCount, "2b");
  459. Assert.AreEqual (1, v.RecursiveReadCount, "2c");
  460. Assert.IsTrue (v.TryEnterReadLock (100), "#3");
  461. Assert.AreEqual (1, v.RecursiveWriteCount, "3b");
  462. Assert.AreEqual (2, v.RecursiveReadCount, "3c");
  463. v.ExitReadLock ();
  464. Assert.AreEqual (1, v.RecursiveWriteCount, "4b");
  465. Assert.AreEqual (1, v.RecursiveReadCount, "4c");
  466. }
  467. [Test]
  468. public void RecursiveUpgradeableReadLockTest ()
  469. {
  470. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  471. Assert.IsTrue (v.TryEnterUpgradeableReadLock (100), "#1");
  472. Assert.IsTrue (v.TryEnterUpgradeableReadLock (100), "#2");
  473. Assert.IsTrue (v.TryEnterUpgradeableReadLock (100), "#3");
  474. Assert.AreEqual (3, v.RecursiveUpgradeCount);
  475. }
  476. [Test]
  477. public void RecursiveReadPropertiesTest ()
  478. {
  479. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  480. v.EnterReadLock ();
  481. v.EnterReadLock ();
  482. Assert.AreEqual (true, v.IsReadLockHeld, "#1a");
  483. Assert.AreEqual (1, v.CurrentReadCount, "#2a");
  484. Assert.AreEqual (2, v.RecursiveReadCount, "#3a");
  485. bool rLock = true;
  486. int cReadCount = -1, rReadCount = -1;
  487. Thread t = new Thread ((_) => {
  488. rLock = v.IsReadLockHeld;
  489. cReadCount = v.CurrentReadCount;
  490. rReadCount = v.RecursiveReadCount;
  491. });
  492. t.Start ();
  493. t.Join ();
  494. Assert.AreEqual (false, rLock, "#1b");
  495. Assert.AreEqual (1, cReadCount, "#2b");
  496. Assert.AreEqual (0, rReadCount, "#3b");
  497. }
  498. [Test]
  499. public void RecursiveUpgradePropertiesTest ()
  500. {
  501. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  502. v.EnterUpgradeableReadLock ();
  503. v.EnterUpgradeableReadLock ();
  504. Assert.AreEqual (true, v.IsUpgradeableReadLockHeld, "#1a");
  505. Assert.AreEqual (false, v.IsReadLockHeld, "#11a");
  506. Assert.AreEqual (0, v.CurrentReadCount, "#2a");
  507. Assert.AreEqual (2, v.RecursiveUpgradeCount, "#3a");
  508. bool upLock = false, rLock = false;
  509. int rCount = -1, rUCount = -1;
  510. Thread t = new Thread ((_) => {
  511. upLock = v.IsUpgradeableReadLockHeld;
  512. rLock = v.IsReadLockHeld;
  513. rCount = v.CurrentReadCount;
  514. rUCount = v.RecursiveUpgradeCount;
  515. });
  516. t.Start ();
  517. t.Join ();
  518. Assert.AreEqual (false, upLock, "#1b");
  519. Assert.AreEqual (false, rLock, "#11b");
  520. Assert.AreEqual (0, rCount, "#2b");
  521. Assert.AreEqual (0, rUCount, "#3b");
  522. }
  523. [Test]
  524. public void RecursiveWritePropertiesTest ()
  525. {
  526. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  527. v.EnterWriteLock ();
  528. v.EnterWriteLock ();
  529. Assert.AreEqual (true, v.IsWriteLockHeld, "#1a");
  530. Assert.AreEqual (2, v.RecursiveWriteCount, "#3a");
  531. bool wLock = false;
  532. int rWrite = -1;
  533. Thread t = new Thread ((_) => {
  534. wLock = v.IsWriteLockHeld;
  535. rWrite = v.RecursiveWriteCount;
  536. });
  537. t.Start ();
  538. t.Join ();
  539. Assert.AreEqual (false, wLock, "#1b");
  540. Assert.AreEqual (0, rWrite, "#3b");
  541. }
  542. [Test]
  543. public void RecursiveEnterExitReadTest ()
  544. {
  545. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  546. v.EnterReadLock ();
  547. v.EnterReadLock ();
  548. v.EnterReadLock ();
  549. Assert.IsTrue (v.IsReadLockHeld);
  550. Assert.AreEqual (3, v.RecursiveReadCount);
  551. v.ExitReadLock ();
  552. Assert.IsTrue (v.IsReadLockHeld);
  553. Assert.AreEqual (2, v.RecursiveReadCount);
  554. }
  555. [Test]
  556. public void RecursiveEnterExitWriteTest ()
  557. {
  558. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  559. v.EnterWriteLock ();
  560. v.EnterWriteLock ();
  561. v.EnterWriteLock ();
  562. Assert.IsTrue (v.IsWriteLockHeld);
  563. Assert.AreEqual (3, v.RecursiveWriteCount);
  564. v.ExitWriteLock ();
  565. v.ExitWriteLock ();
  566. Assert.IsTrue (v.IsWriteLockHeld);
  567. Assert.AreEqual (1, v.RecursiveWriteCount);
  568. }
  569. [Test]
  570. public void RecursiveEnterExitUpgradableTest ()
  571. {
  572. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  573. v.EnterUpgradeableReadLock ();
  574. v.EnterUpgradeableReadLock ();
  575. v.EnterUpgradeableReadLock ();
  576. Assert.IsTrue (v.IsUpgradeableReadLockHeld);
  577. Assert.AreEqual (3, v.RecursiveUpgradeCount);
  578. v.ExitUpgradeableReadLock ();
  579. Assert.IsTrue (v.IsUpgradeableReadLockHeld);
  580. Assert.AreEqual (2, v.RecursiveUpgradeCount);
  581. }
  582. [Test]
  583. public void RecursiveWriteUpgradeReadTest ()
  584. {
  585. var rwlock = new ReaderWriterLockSlim(LockRecursionPolicy.SupportsRecursion);
  586. rwlock.EnterWriteLock ();
  587. Assert.IsTrue (rwlock.IsWriteLockHeld);
  588. rwlock.EnterUpgradeableReadLock ();
  589. Assert.IsTrue (rwlock.IsUpgradeableReadLockHeld);
  590. rwlock.EnterReadLock ();
  591. Assert.IsTrue (rwlock.IsReadLockHeld);
  592. rwlock.ExitUpgradeableReadLock();
  593. Assert.IsFalse (rwlock.IsUpgradeableReadLockHeld);
  594. Assert.IsTrue (rwlock.IsReadLockHeld);
  595. Assert.IsTrue (rwlock.IsWriteLockHeld);
  596. rwlock.ExitReadLock ();
  597. Assert.IsTrue (rwlock.IsWriteLockHeld);
  598. }
  599. [Test]
  600. public void RecursiveWriteUpgradeTest ()
  601. {
  602. ReaderWriterLockSlim rwlock = new ReaderWriterLockSlim(LockRecursionPolicy.SupportsRecursion);
  603. rwlock.EnterWriteLock ();
  604. Assert.IsTrue (rwlock.IsWriteLockHeld);
  605. rwlock.EnterUpgradeableReadLock ();
  606. Assert.IsTrue (rwlock.IsUpgradeableReadLockHeld);
  607. rwlock.ExitUpgradeableReadLock ();
  608. Assert.IsFalse (rwlock.IsUpgradeableReadLockHeld);
  609. Assert.IsTrue (rwlock.IsWriteLockHeld);
  610. rwlock.ExitWriteLock ();
  611. Assert.IsFalse (rwlock.IsWriteLockHeld);
  612. rwlock.EnterWriteLock ();
  613. Assert.IsTrue (rwlock.IsWriteLockHeld);
  614. }
  615. [Test]
  616. public void RecursiveWriteReadAcquisitionInterleaving ()
  617. {
  618. var v = new ReaderWriterLockSlim (LockRecursionPolicy.SupportsRecursion);
  619. v.EnterWriteLock ();
  620. Assert.IsTrue (v.IsWriteLockHeld, "#1");
  621. bool result = true;
  622. var t = new Thread (delegate () {
  623. result = v.TryEnterReadLock (100);
  624. });
  625. t.Start ();
  626. t.Join ();
  627. Assert.IsFalse (result, "#2");
  628. v.ExitWriteLock ();
  629. t = new Thread (delegate () {
  630. result = v.TryEnterReadLock (100);
  631. });
  632. t.Start ();
  633. t.Join ();
  634. Assert.IsTrue (result, "#3");
  635. }
  636. }
  637. }