Os_project_1.rar_MPI

import java.util.*; import java.util.concurrent.TimeUnit; import java.text.SimpleDateFormat; //--------------------------------------------------------------- public class Hamburger { static Queue que = new LinkedList(); static semaphore sem = new semaphore(0); static semaphore mutex = new semaphore(1); //---------------------------------------------------------------- static class Producer extends Thread { String namep; long startTimep; public Producer(String name) { this.namep = name; startTimep = System.currentTimeMillis(); } public void run() { try { long start = System.currentTimeMillis(); long end = start + 100*1000;// simulated for 30 seconds. Produce for ...seconds int a = 1; while (System.currentTimeMillis() < end) { //TimeUnit.SECONDS.sleep(1); mutex.waits(); a=a+1;//new Integer(N); que.add(a); long estimatedTime = System.currentTimeMillis() - startTimep; System.out.println("producer: "+namep+" Produces "+que.peek()+" at the time: "+estimatedTime); mutex.signal(); sem.signal(); Thread.sleep(1000); } } catch (Exception x) { x.printStackTrace(); } } } //----------------------------------------------------------------------------------------------------------- static class Consumer extends Thread { long startTime; String namec; long servicetime; int count=1; public int eat(Object obj) { return (this.count++); } public Consumer(String name) { //eat=0; this.namec = name; startTime = System.currentTimeMillis(); } public void run() { try { while (true) { sem.waits(); mutex.waits(); long estimatedTime = System.currentTimeMillis() - startTime; System.out.print("Consumer: "+ namec+" eats "+ que.poll()+" at the time: "+estimatedTime); System.out.println(" Totall Hamburgers: "+ eat(this.namec)); //TimeUnit.SECONDS.sleep(1); mutex.signal(); Thread.sleep(1000); } } catch (Exception x) { x.printStackTrace(); } } } //---------------------------------------------------------------------------------------------------- public static void main(String [] args) { System.out.print("This program Simulated Running Producer/Consumer problem\nWith two producers and five consumers\nfor 100 seconds\n\n"); System.out.println("Enter '1' and press Enter key to continue..."); Scanner scan = new Scanner(System.in); String s = scan.next(); new Producer("prod1 ").start(); new Producer("prod2 ").start(); new Consumer("Ali ").start(); new Consumer("Mohsen ").start(); new Consumer("Milad ").start(); new Consumer("Danial ").start(); } }