public class SharedBufferTest2
1: //SharedBufferTest2.java
2: //SharedBufferTest2creates producer and consumer threads.
3:
4: public class SharedBufferTest2
5: {
6: public static void main( String [] args )
7: {
8: // create shared object used by threads; we use a SynchronizedBuffer
9: // reference rather than a Buffer reference so we can invoke
10: // SynchronizedBuffer method displayState from main
11: SynchronizedBuffer sharedLocation = new SynchronizedBuffer();
12:
13: // Display column heads for output
14: StringBuffer columnHeads = new StringBuffer( "Operation" );
15: String blanks = new String("");
16: for (int j=1; j<=40-"Operation".length(); j++) blanks += " ";
17: columnHeads.append(blanks);
18: //columnHeads.setLength( 40 );
19: columnHeads.append( "Buffer\t\tOccupied Count" );
20: System.err.println( columnHeads );
21: System.err.println();
22: sharedLocation.displayState( "Initial State" );
23:
24: // create producer and consumer objects
25: Producer producer = new Producer( sharedLocation );
26: Consumer consumer = new Consumer( sharedLocation );
27:
28: producer.start(); // start producer thread
29: consumer.start(); // start consumer thread
30:
31: } // end main
32:
33: } // end class SharedBufferTest2
34: