blockingQueue多线程中的小列子

package com.demo;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import org.apache.log4j.Logger;

/**
 * QueueThread.java,2009-11-17,lijunjie
 *
 * MessageService project is a  Value-added service Platform base on
 *  message  application
 *
 * Copyright (c) 2009-2012 95OL Beijing  Inc
 * All right reserved.
 * This software is the proprietary information of 95ol, Inc.
 *
 */

public abstract class QueueThread  {
	private BlockingQueue blockQueue=new LinkedBlockingQueue();
	static Logger logger=Logger.getLogger(QueueThread.class);

	private Thread thread=null;
	private String name=null;


	public void setQueue(BlockingQueue blockQueue)
	{
		this.blockQueue=blockQueue;
	}
	
	protected BlockingQueue getQueue()
	{
		return this.blockQueue;
	}

	
	private Thread getThread()
	{
		if(thread==null)
		{
		thread=new Thread(){
			public void run()
			{
				QueueThread.this.run();
			}
		};
		}
		
		return thread;
	}
	public void add(Object o)
	{
		try {
			blockQueue.put(o);
			
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	public void run() {
		while(true)
		{
			try{
				
				Object o=blockQueue.take();
				handle(o);
			}
			catch(InterruptedException e)
			{
				e.printStackTrace();
			}
			
			
		}
		// TODO Auto-generated method stub
		
	}
	
	public abstract void handle(Object o);
	
	public String toString()
	{
		return "Thread name:"+name+",Queue size:"+blockQueue.size();
	}
	
	public QueueThread setName(String name)
	{
		this.name=name;
		this.getThread().setName(name);
		return this;
	}
	
	public QueueThread setPriority(int prio)
	{
		this.getThread().setPriority(prio);
		return this;
		
	}
	
	public QueueThread start()
	{
		this.getThread().setPriority(Thread.NORM_PRIORITY);
		this.getThread().start();
		return this;
	}
	
	
	public static void main(String[] args)
	{
		BlockingQueue blockingQueue=new LinkedBlockingQueue();
		QueueThread queueThread=new QueueThread(){
			public void handle(Object o)
			{
				System.out.println(">>>"+o);
			}
		};
		queueThread.setName("test").setQueue(blockingQueue);
		queueThread.start();
		
		
		for(int i=0;i<100;i++)
		{
			ProductThread pt=new ProductThread(queueThread);
			pt.start();
		}
		
	}
	

}


class ProductThread extends Thread
{
	BlockingQueue blockingQueue=null;
	public ProductThread(QueueThread queueThread)
	{
		blockingQueue=queueThread.getQueue();
	}
	
	public void run()
	{
		for(int i=0;i<10;i++)
		{
			System.out.println("<<<"+i);
			blockingQueue.add(i);
		}
	}
}