producer.cs

北大青鸟内部资料

using System;
using System.Threading;

namespace Multithreading
{
	/// <summary>
	/// Summary description for Producer.
	/// </summary>
	class Producer 
	{
		private SharedIntegerSynchronized objSharedLocation;
		
		// constructor
		public Producer( 
			SharedIntegerSynchronized objShared)
		{
			objSharedLocation = objShared;
		}

		// store values 1-4 in object objSharedLocation
		public void Produce()
		{
			// sleep for interval 400 milliseconds
			// then set objSharedLocation's Buffer property
			for ( int count = 1; count <= 4; count++ ) 
			{
				Thread.Sleep( 400 );
				objSharedLocation.Buffer = count; 
			}

			Console.WriteLine( Thread.CurrentThread.Name + 
				" 完成生成。\n终止 " + 
				Thread.CurrentThread.Name + "。\n" );

		} // end method Produce

	} // end class Producer
}