Page History

public class MissedSignal implements Runnable {
  private static final Object lock = new Object();
  private static int buffer_count = 5;
  private static int number; // Selects function based on thread number	
  
  public void setThreadNumber(int num) {
    number = num;
  }

  public void run (){
    synchronized(lock) {
      try {    	  
        if(number == 1) {	  
          while(buffer_count == 0) { 
      	    lock.wait();		  
      	  }  
      	} else if(number == 2) {  	    		  
      	  while(buffer_count == 10) {	
      	    lock.wait();   	    		    	        	    
      	  }
      	} else if(number == 3) {	   
          lock.notify();      	   		  
        } 	    	  
      } catch (InterruptedException ie) {
        // Handle the exception
      }
    }	  
  }

  public static void makeThread1True(setThreadParameters(int threadNumber, int bufferCount) {
    buffer_countnumber = 0threadNumber;
  }
  buffer_count      = bufferCount;
  public static void makeThread2True() {}
    buffer_count = 10;
  }
        
  public static void main(String[] args) throws IOException, InterruptedException {    
    MissedSignal ms = new MissedSignal();
     
    makeThread1True();
    ms.setThreadNumber(1);
for(int i = 0; i < 3; i++) {    new Thread(ms).start();
     // 
Buffer count does  Thread.sleep(1000);
   not matter for third thread
    makeThread2True();
    ms.setThreadNumber(2);
    new Thread(ms).start();
   
    Thread.sleep(1000);  setThreadParameters(i + 1, i * 10); // Sets buffer count for threads in the sequence: 0, 10, 20
      
    ms.setThreadNumber(3new Thread(ms).start();
     new Thread(ms).startsleep(1000);
    }
  }
}