C#

<br />
// MonitorSample.cs<br />
// This example shows use of the following methods of the C# lock keyword<br />
// and the Monitor class <br />
// in threads:<br />
//      Monitor.Pulse(Object)<br />
//      Monitor.Wait(Object)<br />
using System;<br />
using System.Threading;<br />
<br />
public class MonitorSample<br />
{<br />
	public static void Main(String[] args)<br />
	{<br />
		int result = 0;   // Result initialized to say there is no error<br />
		Cell cell = new Cell( );<br />
<br />
		CellProd prod = new CellProd(cell, 20);  // Use cell for storage, <br />
		// produce 20 items<br />
		CellCons cons = new CellCons(cell, 20);  // Use cell for storage, <br />
		// consume 20 items<br />
<br />
		Thread producer = new Thread(new ThreadStart(prod.ThreadRun));<br />
		Thread consumer = new Thread(new ThreadStart(cons.ThreadRun));<br />
		// Threads producer and consumer have been created, <br />
		// but not started at this point.<br />
<br />
		try<br />
		{<br />
			producer.Start( );<br />
			consumer.Start( );<br />
<br />
			producer.Join( );   // Join both threads with no timeout<br />
			// Run both until done.<br />
			consumer.Join( );  <br />
			// threads producer and consumer have finished at this point.<br />
		}<br />
		catch (ThreadStateException e)<br />
		{<br />
			Console.WriteLine(e);  // Display text of exception<br />
			result = 1;            // Result says there was an error<br />
		}<br />
		catch (ThreadInterruptedException e)<br />
		{<br />
			Console.WriteLine(e);  // This exception means that the thread<br />
			// was interrupted during a Wait<br />
			result = 1;            // Result says there was an error<br />
		}<br />
		// Even though Main returns void, this provides a return code to <br />
		// the parent process.<br />
		Environment.ExitCode = result;<br />
<br />
		Console.WriteLine("Finished");<br />
		Console.ReadLine();<br />
	}<br />
}<br />
<br />
public class CellProd<br />
{<br />
	Cell cell;         // Field to hold cell object to be used<br />
	int quantity = 1;  // Field for how many items to produce in cell<br />
<br />
	public CellProd(Cell box, int request)<br />
	{<br />
		cell = box;          // Pass in what cell object to be used<br />
		quantity = request;  // Pass in how many items to produce in cell<br />
	}<br />
	public void ThreadRun( )<br />
	{<br />
		for(int looper=1; looper<=quantity; looper++)<br />
			cell.WriteToCell(looper);  // "producing"<br />
	}<br />
}<br />
<br />
public class CellCons<br />
{<br />
	Cell cell;         // Field to hold cell object to be used<br />
	int quantity = 1;  // Field for how many items to consume from cell<br />
<br />
	public CellCons(Cell box, int request)<br />
	{<br />
		cell = box;          // Pass in what cell object to be used<br />
		quantity = request;  // Pass in how many items to consume from cell<br />
	}<br />
	public void ThreadRun( )<br />
	{<br />
		int valReturned;<br />
		for(int looper=1; looper<=quantity; looper++)<br />
			// Consume the result by placing it in valReturned.<br />
			valReturned=cell.ReadFromCell( );<br />
	}<br />
}<br />
<br />
public class Cell<br />
{<br />
	int cellContents;         // Cell contents<br />
	bool readerFlag = false;  // State flag<br />
	public int ReadFromCell( )<br />
	{<br />
		lock(this)   // Enter synchronization block<br />
		{<br />
			Console.WriteLine("Enter ReadFromCell()");<br />
			if (!readerFlag)<br />
			{            // Wait until Cell.WriteToCell is done producing<br />
				try<br />
				{<br />
					// Waits for the Monitor.Pulse in WriteToCell<br />
					Monitor.Wait(this);<br />
				}<br />
				catch (SynchronizationLockException e)<br />
				{<br />
					Console.WriteLine(e);<br />
				}<br />
				catch (ThreadInterruptedException e)<br />
				{<br />
					Console.WriteLine(e);<br />
				}<br />
			}<br />
			Console.WriteLine("Consume: {0}",cellContents);<br />
			readerFlag = false;    // Reset the state flag to say consuming<br />
			// is done.<br />
			Monitor.Pulse(this);   // Pulse tells Cell.WriteToCell that<br />
			// Cell.ReadFromCell is done.<br />
			Console.WriteLine("Exit ReadFromCell()");<br />
		}   // Exit synchronization block<br />
		return cellContents;<br />
	}<br />
   <br />
	public void WriteToCell(int n)<br />
	{<br />
		lock(this)  // Enter synchronization block<br />
		{<br />
			Console.WriteLine("Enter WriteToCell()");<br />
			if (readerFlag)<br />
			{      // Wait until Cell.ReadFromCell is done consuming.<br />
				try<br />
				{<br />
					Monitor.Wait(this);   // Wait for the Monitor.Pulse in<br />
					// ReadFromCell<br />
				}<br />
				catch (SynchronizationLockException e)<br />
				{<br />
					Console.WriteLine(e);<br />
				}<br />
				catch (ThreadInterruptedException e)<br />
				{<br />
					Console.WriteLine(e);<br />
				}<br />
			}<br />
			cellContents = n;<br />
			Console.WriteLine("Produce: {0}",cellContents);<br />
			readerFlag = true;    // Reset the state flag to say producing<br />
			// is done<br />
			Monitor.Pulse(this);  // Pulse tells Cell.ReadFromCell that <br />
			// Cell.WriteToCell is done.<br />
			Console.WriteLine("Exit WriteToCell()");<br />
		}   // Exit synchronization block<br />
	}<br />
}<br />