sharedcell.cs

北大青鸟内部资料

using System;
using System.Threading;

namespace Multithreading
{
	/// <summary>
	/// Summary description for SharedCell.
	/// </summary>
	class SharedCell
	{
		// create producer and objConsumer threads and start them
		static void Main( string[] args )
		{
			// create shared object used by threads
			SharedIntegerSynchronized objSharedInteger = 
				new SharedIntegerSynchronized();

			// Random object used by each thread
			Random random = new Random();

			// create Producer and Consumer objects
			Producer producer = 
				new Producer( objSharedInteger, random );

			Consumer objConsumer = 
				new Consumer( objSharedInteger, random );

			// output column heads and initial buffer state
			Console.WriteLine( "{0,-35}{1,-9}{2}\n",
				"Operation", "Buffer", "Occupied Count" );
			objSharedInteger.DisplayState( "Initial state"  );

			// create threads for producer and objConsumer and set 
			// delegates for each thread
			Thread producerThread = 
				new Thread( new ThreadStart( producer.Produce ) );
			producerThread.Name = "Producer";

			Thread objConsumerThread = 
				new Thread( new ThreadStart( objConsumer.Consume ) );
			objConsumerThread.Name = "Consumer";

			// start each thread
			producerThread.Start();
			objConsumerThread.Start();

		} // end method Main

	} // end class SharedCell
}