joinedrequestbuffer.java

来自「一个基于NetBeans平台开发的」· Java 代码 · 共 24 行

package com.sinpool.rivercrescent.BufferZone;

import java.util.Vector;

public class JoinedRequestBuffer{
	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 RequestBuffer被唤醒");notify();flag = false;} }catch (Exception e) {}
	}
	public synchronized Object get(int i){
		if (messageList.size() == 0)  flag = true;
		try{if (flag) {System.out.println("join RequestBuffer阻塞");wait();} }catch (Exception e) {}
		return messageList.get(i);
	}
	public synchronized int size(){
		return messageList.size();
	}
	public synchronized void remove(Object o){
		if (messageList.remove(o)) System.out.println("在JoinedRequestBuffer 成功删除了一个通告。");
	}
}