public class DataDealer
{
? ? private final Buffer dataBuffer; // 数据buffer，因为使用匿名类，所以声明为final

? ? public DataDealer()
? ? {
? ?? ???// 初始化阻塞队列，原始队列是一个无边界的先进先出队列，也是Apache的同一个库中提供的
? ?? ???dataBuffer = BlockingBuffer.decorate( new UnboundedFifoBuffer(??) );

? ?? ???// 创建数据处理线程
? ?? ???Thread dealThread = new Thread( new Runnable()
? ?? ???{
? ?? ?? ?? ?public void run()
? ?? ?? ?? ?{
? ?? ?? ?? ?? ? while ( true )? ?// 永远尝试获得数据并处理，因此死循环
? ?? ?? ?? ?? ? {
? ?? ?? ?? ?? ?? ???System.out.println( "尝试获取要处理的数据" );
? ?? ?? ?? ?? ?? ???Object toDeal = dataBuffer.remove(); // 如果拿不到数据，就会阻塞
? ?? ?? ?? ?? ?? ???System.out.println( "dealing:" + toDeal ); // 真正的业务处理代码就在这里
? ?? ?? ?? ?? ?? ???System.out.println( "数据处理完毕" );
? ?? ?? ?? ?? ? }
? ?? ?? ?? ?}
? ?? ???}, "数据处理线程" );

? ?? ???dealThread.setDaemon( true );??// 将这个数据处理线程设置为守护线程，如果主线程退出，那么个数据处理线程也自动退出
? ?? ???dealThread.start();??// 启动这个线程
? ? }

? ? // 外部业务方法就简单了，调用这个方法提交一个要处理的对象，其实现逻辑只是将其加入队列而已
? ? public void addDataToWrite( Object toWhite )
? ? {
? ?? ???dataBuffer.add( toWhite );
? ? }

}