messagequeue.java

《JSP时尚编程百例》源代码41-60

  package beans ;
  
  import java.io.* ;
  import java.lang.* ;
  import java.util.* ;
  import beans.* ;

  public class MessageQueue {
    private Object lockKey ;
    private Vector msgQueue ;
    private int maxNumMessages ;

    public MessageQueue() {
      this.lockKey=new Object() ;
      this.msgQueue=new Vector() ;
      this.maxNumMessages=10 ;
    }


    public String getMessages() {
      String  htmlCode="" ;

      synchronized( lockKey ) {
    // Enter critical-region.
        for( Enumeration e=this.msgQueue.elements() ; e.hasMoreElements() ; )
      	  htmlCode+=( "<p>"+(String)e.nextElement()+"</p>\n" ) ;
    // Leave critical-region.
      }
      
      return htmlCode ;
    }


    public void setMaxNumMessages( String num ) {
      try {
      	this.maxNumMessages=Integer.parseInt( num ) ;
      }
      catch( NumberFormatException ex ) {
       	this.maxNumMessages=10 ;
      }
    }


    public void setMessage( String msg ) {
      synchronized( lockKey ) {
    // Enter critical-region.
        this.msgQueue.insertElementAt( msg, 0 ) ;
        int numMessages=this.msgQueue.size() ;
        if( numMessages>this.maxNumMessages )
          this.msgQueue.removeElementAt( numMessages-1 ) ;
    // Leave critical-region.
      }
    }
  }