ReaderWriterLockSlimTest.cs 19 KB

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