PriorityBlockingQueue 우선 순위 규칙

public class TestPriorityQueue {
	
	static Random r=new Random(47);
	
	public static void main(String args[]){
		final PriorityBlockingQueue q=new PriorityBlockingQueue();
		ExecutorService se=Executors.newCachedThreadPool();
		//execute producer
		se.execute(new Runnable(){
			public void run() {
				int i=0;
				while(true){
					q.put(new PriorityEntity(r.nextInt(10),i++));
					try {
						TimeUnit.MILLISECONDS.sleep(r.nextInt(1000));
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			}
		});
		
		//execute consumer
		se.execute(new Runnable(){
			public void run() {
				while(true){
					try {
						out.println("take-- "+q.take()+" left:-- ["+q.toString()+"]");
						try {
							TimeUnit.MILLISECONDS.sleep(r.nextInt(1000));
						} catch (InterruptedException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}
		});
		try {
			TimeUnit.SECONDS.sleep(5);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		out.println("shutdown");
	}

}

class PriorityEntity implements Comparable<PriorityEntity> {
	private static int count=0;
	private int id=count++;
	private int priority;
	private int index=0;

	public PriorityEntity(int _priority,int _index) {
		this.priority = _priority;
		this.index=_index;
	}
	
	public String toString(){
		return id+"# [index="+index+" priority="+priority+"]";
	}

	// ， 
	public int compareTo(PriorityEntity o) {
		return this.priority > o.priority ? 1
				: this.priority < o.priority ? -1 : 0;
	}

	// ， 
//	public int compareTo(PriorityTask o) {
//		return this.priority < o.priority ? 1
//				: this.priority > o.priority ? -1 : 0;
//	}
}