TestBoundChannel.cs

using System;
using ConcurrencyUtilities;
using System.Collections.Generic;
using System.Threading;

namespace TestConcurrencyUtilities
{
	// Test my BoundChannel class
	public class TestBoundChannel: TestChannelUtilities
	{
		static int _takeThreadsDelayTime;

		public static void Run(int testMagnitude, int upperLimit, int sleepTime = 0) {
			_testMagnitude = testMagnitude;
			_sleepTime = sleepTime;
			_channel = new BoundChannel<string>(upperLimit);

			_takeThreadsDelayTime = _sleepTime * 5;

			List<Thread> threads;

			TestSupport.Log(ConsoleColor.Blue, "Bound channel test\n==============================");
			TestSupport.Log(ConsoleColor.Blue, "\nBound channel size: " + upperLimit +
			                   "\nThe take threads will start after a delay of " +
			                TestSupport.StringFromMilliseconds(_takeThreadsDelayTime));

			Console.WriteLine("\nStarting Put threads...");
			threads = TestSupport.CreateThreads(ChannelPut, "BoundChannelPutThread", _testMagnitude, 0);
			threads.Add(new Thread(DelayChannelTakeThreads));
			TestSupport.RunThreads(threads);
		}

		public static void DelayChannelTakeThreads() {
			List<Thread> channelTakeThreads = TestSupport.CreateThreads(ChannelTake,
			                                     "            BoundChannelTakeThread", _testMagnitude, 0);
			TestSupport.SleepThread(_takeThreadsDelayTime, "\nWill shortly start Take threads...");
			TestSupport.RunThreads(channelTakeThreads);
		}
	}
}