Java Coding Assignment- Multi-Threading

profileKnockKnockDragon
Consumer.java

package part2; //Consumer's run method loops ten times reading a value from buffer. import java.util.Random; public class Consumer implements Runnable { private static Random generator = new Random(); private Buffer sharedLocation; // reference to shared object // constructor public Consumer( Buffer shared ) { sharedLocation = shared; } // end Consumer constructor // read sharedLocation's value four times and sum the values public void run() { int sum = 0; for ( int count = 1; count <= 10; count++ ) { // sleep 0 to 3 seconds, read value from buffer and add to sum try { Thread.sleep( generator.nextInt( 50 ) ); sum += sharedLocation.get(); // uncomment next line for unsync version - //System.out.printf( "\t\t\t%2d\n", sum ); } // end try // if sleeping thread interrupted, print stack trace catch ( InterruptedException exception ) { exception.printStackTrace(); } // end catch } // end for System.out.printf( "\n%s %d.\n%s\n", "Consumer read values totaling", sum, " Terminating Consumer Thread. " ); } // end method run } // end class Consumer