joineduploadmessagebuffer.java

一个基于NetBeans平台开发的

package com.sinpool.rivercrescent.BufferZone;

import java.util.Vector;
import com.sinpool.rivercrescent.interfaces.JoinedMessageBufferInterface;

public class JoinedUploadMessageBuffer implements JoinedMessageBufferInterface{
	private Vector MessageList = new Vector(5,5);
	private boolean flag = false;
	
	public synchronized void addElement(Object o){
		MessageList.addElement(o);
		try{if (flag) {System.out.println("join UploadMessageBuffer 被唤醒");notify();flag = false;} }catch (Exception e) {}
	}
	public synchronized Object getMessage(int i){
		
		if (MessageList.size() == 0)  flag = true;
		try{if (flag) {System.out.println("join UploadMessageBuffer 阻塞");wait();} }catch (Exception e) {}
		return MessageList.get(i);
	}
	public synchronized int size(){
		return MessageList.size();
	}
	public synchronized void remove(Object o){
		MessageList.remove(o);
	}
}