public static void main(String[] args){
		final ThreadPoolExecutor pool = new ThreadPoolExecutor(5, 100, 1, TimeUnit.SECONDS,  
                new ArrayBlockingQueue<Runnable>(5000),new ThreadPoolExecutor.CallerRunsPolicy());  
		int total=0;
		final AtomicLong count=new AtomicLong();
		final Set<String> resultSet=new CopyOnWriteArraySet<String>();	
		for(long i=0;i<=100000;i++){	
			try{
				pool.execute(new Runnable() {
 
					@Override
					public void run() {
						try{
							Thread.sleep(20l);
							resultSet.add(count.addAndGet(1)+"");
						}catch(Exception e){
							//ignore
						}	
 
					}
				});
			}catch(Exception e){
				e.printStackTrace();
			}
			total++;				
		}	
		pool.shutdown();
		System.out.println(pool.getActiveCount());
		try{
			pool.awaitTermination(5, TimeUnit.MINUTES);
		}catch(Exception e){
 
		}
		System.out.println(pool.getActiveCount());
		for(String s : resultSet){
			System.out.println(s);
		}
	}