consumer.java

此源码是实现线程间同步互斥的算法

package jthreadsynch;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */

public class Consumer extends Thread {
  MainFrame frame;
  static boolean stopped;

  public Consumer(MainFrame frame) {
    this.frame=frame;
    this.stopped=false;
  }
  public void run() {
    /**@todo Override this java.lang.Thread method*/
    while(true){
      if(stopped)
        break;
      int i=this.frame.getSharedData();
      this.frame.jProgressBar1.setValue(i);
      this.frame.jProgressBar1.setString("Consuming "+String.valueOf(i)+"%");
      try{
        this.sleep(100);
      }catch(Exception err){}

    }

  }
}