管道过滤器的实现java

管道过滤器的实现java，希望大家能够一起学习，我只是将文件放到了里面，希望大家自己搭建工程

package ch03.pipesfilteres;

import java.util.ArrayDeque;

public class DataSink extends Filter{
	private	FilterImpl observer;
	
	protected ArrayDeque received = new ArrayDeque（）;
	
	public DataSink（Pipe in） {
		super（innull）;
		observer = null;
	}
	public int size（） {
		return received.size（）;
	}
	
	public Packet nextPacket（） {
		Packet p = received.getLast（）;
		received.pollLast（）;
		return p;
	}
	public void customNotify（） {
		try {
			while（input.size（） > 0） {
				received.addFirst（input.read（））;
			}
		} catch （EmptyPipeException e） {
			System.err.println（“ empty pipe. “）;
		}
		if（observer != null）
			observer.customNotify（）;
	}

	public void setObserver（FilterImpl observer） {
		this.observer = observer;
	}
	public FilterImpl getObserver（） {
		return observer;
	}
	@Override
	public void process（） {
		try {
			int i=0;
			for（i=0;i<4;i++）{
				System.out.println（input.read（）+“已经进入了数据池“）;
				}
			
		} catch （EmptyPipeException e） {
			e.printStackTrace（）;
		}
		
	}
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2012-11-20 19:40  pipesfilteres\
     文件        1067  2012-11-20 19:38  pipesfilteres\DataSink.java
     文件         428  2012-11-20 19:33  pipesfilteres\DataSource.java
     文件          89  2012-11-20 19:39  pipesfilteres\EmptyPipeException.java
     文件         224  2012-09-10 17:34  pipesfilteres\Filter.java
     文件         544  2012-11-20 19:35  pipesfilteres\FilterImpl.java
     文件          93  2012-09-10 15:41  pipesfilteres\NoOutputPipeException.java
     文件         335  2012-11-20 18:35  pipesfilteres\Packet.java
     文件         535  2012-11-20 19:33  pipesfilteres\Pipe.java
     文件         472  2012-11-20 19:35  pipesfilteres\TestPipes.java