Add random sleep intervals to increase chances of thread interleaving

michaelklishin · michaelklishin · commit 6b172e6540b3 · 2014-04-16T18:02:24.000+04:00
We don't have much control over VM scheduler, so will have to
do this.
diff --git a/projects/client/Unit/src/unit/TestExchangeDeclare.cs b/projects/client/Unit/src/unit/TestExchangeDeclare.cs
@@ -54,6 +54,7 @@ public class TestExchangeDeclare : IntegrationFixture {
         public void TestConcurrentQueueDeclare()
         {
             string x = GenerateExchangeName();
+            Random rnd = new Random();
 
             List<Thread> ts = new List<Thread>();
             System.NotSupportedException nse = null;
@@ -63,6 +64,9 @@ public void TestConcurrentQueueDeclare()
                         {
                             try
                             {
+                                // sleep for a random amount of time to increase the chances
+                                // of thread interleaving. MK.
+                                Thread.Sleep(rnd.Next(5, 500));
                                 Model.ExchangeDeclare(x, "fanout", false, false, null);
                             } catch (System.NotSupportedException e)
                             {
diff --git a/projects/client/Unit/src/unit/TestQueueDeclare.cs b/projects/client/Unit/src/unit/TestQueueDeclare.cs
@@ -54,6 +54,7 @@ public class TestQueueDeclare : IntegrationFixture {
         public void TestConcurrentQueueDeclare()
         {
             string q = GenerateQueueName();
+            Random rnd = new Random();
 
             List<Thread> ts = new List<Thread>();
             System.NotSupportedException nse = null;
@@ -63,6 +64,9 @@ public void TestConcurrentQueueDeclare()
                         {
                             try
                             {
+                                // sleep for a random amount of time to increase the chances
+                                // of thread interleaving. MK.
+                                Thread.Sleep(rnd.Next(5, 500));
                                 Model.QueueDeclare(q, false, false, false, null);
                             } catch (System.NotSupportedException e)
                             {

Original file line number	Diff line number	Diff line change
`@@ -54,6 +54,7 @@ public class TestExchangeDeclare : IntegrationFixture {`
`54`	`54`	`public void TestConcurrentQueueDeclare()`
`55`	`55`	`{`
`56`	`56`	`string x = GenerateExchangeName();`
	`57`	`+ Random rnd = new Random();`
`57`	`58`
`58`	`59`	`List<Thread> ts = new List<Thread>();`
`59`	`60`	`System.NotSupportedException nse = null;`
`@@ -63,6 +64,9 @@ public void TestConcurrentQueueDeclare()`
`63`	`64`	`{`
`64`	`65`	`try`
`65`	`66`	`{`
	`67`	`+ // sleep for a random amount of time to increase the chances`
	`68`	`+ // of thread interleaving. MK.`
	`69`	`+ Thread.Sleep(rnd.Next(5, 500));`
`66`	`70`	`Model.ExchangeDeclare(x, "fanout", false, false, null);`
`67`	`71`	`} catch (System.NotSupportedException e)`
`68`	`72`	`{`
Original file line number	Diff line number	Diff line change
`@@ -54,6 +54,7 @@ public class TestQueueDeclare : IntegrationFixture {`
`54`	`54`	`public void TestConcurrentQueueDeclare()`
`55`	`55`	`{`
`56`	`56`	`string q = GenerateQueueName();`
	`57`	`+ Random rnd = new Random();`
`57`	`58`
`58`	`59`	`List<Thread> ts = new List<Thread>();`
`59`	`60`	`System.NotSupportedException nse = null;`
`@@ -63,6 +64,9 @@ public void TestConcurrentQueueDeclare()`
`63`	`64`	`{`
`64`	`65`	`try`
`65`	`66`	`{`
	`67`	`+ // sleep for a random amount of time to increase the chances`
	`68`	`+ // of thread interleaving. MK.`
	`69`	`+ Thread.Sleep(rnd.Next(5, 500));`
`66`	`70`	`Model.QueueDeclare(q, false, false, false, null);`
`67`	`71`	`} catch (System.NotSupportedException e)`
`68`	`72`	`{`