同步类容器和并发类容器

```
BlockingQueue<String> synchronousQueue = new SynchronousQueue<>();
synchronousQueue.add("a");
```

```
public class SynQueue {

	public static void main(String[] args) {
		SynchronousQueue<String> queue = new SynchronousQueue<>();
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("-----" + queue.take() + "\n");
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		},"t1");
		t1.start();
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				queue.add("aaaa");//先take()取出阻塞，当有元素添加，后才取出
				queue.add("bbbb");
			}
		},"t2");
		t2.start();
	}
}
```　

public class Task implements Comparable<Task>{

	private int id;
	private String name;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	@Override
	public int compareTo(Task o) {
		return this.id > o.id ? 1 : (this.id < o.id ? -1 : 0);
	}
	@Override
	public String toString() {
		return this.id + "," + this.name;
	}
}

public class UsePriorityBlockingQueue {

	public static void main(String[] args) {
		PriorityBlockingQueue<Task> queue = new PriorityBlockingQueue<>();
		Task t1 = new Task();
		t1.setId(3);
		t1.setName("task1");
		Task t2 = new Task();
		t2.setId(6);
		t2.setName("task2");
		Task t3 = new Task();
		t3.setId(1);
		t3.setName("task3");
		queue.add(t1);
		queue.add(t2);
		queue.add(t3);
		System.out.println(queue);
		try {
			System.out.println(queue.peek());//peek和element取出但不移除
			System.out.println(queue.take());//take、poll和remove取出且移除
			//优先级排序，并返回优先级最高的元素，并在队列中删除取出的元素
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println(queue);
		for (Iterator<Task> iter = queue.iterator() ; iter.hasNext();) {
			Task task = iter.next();
			System.out.println(task.getName());
		}
	}
}

public class Wangmin implements Delayed{

	private String id;
	private String name;
	private long endTime;
	private TimeUnit timeUnit = TimeUnit.SECONDS; //设定单位为秒
	
	public Wangmin(String id, String name, long endTime) {
		super();
		this.id = id;
		this.name = name;
		this.endTime = endTime;
	}
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public long getEndTime() {
		return endTime;
	}
	public void setEndTime(long endTime) {
		this.endTime = endTime;
	}
	
	/**
	 * 上网时间相互比较，确定排序
	 */
	@Override
	public int compareTo(Delayed o) {
		Wangmin min = (Wangmin)o;
		return this.getDelay(this.timeUnit) - min.getDelay(this.timeUnit) > 0 ? 1 : 0;
	}
	/**
	 * 返回延迟时间
	 */
	@Override
	public long getDelay(TimeUnit unit) {
		return this.endTime - System.currentTimeMillis();
	}
	
}


public class WangBa implements Runnable{

	private DelayQueue<Wangmin> delayQueue = new DelayQueue<Wangmin>();
	public boolean yinye = true;
	
	public void shangji(String name, String id, int money) {
		Wangmin min = new Wangmin(id, name, money * 1000 + System.currentTimeMillis());
		System.out.println("网民：" + min.getName() + "，身份证号码为：" + min.getId() + "，网费：" + money + "\t开始上网，上网结束时间为：" + min.getEndTime());
		this.delayQueue.add(min);
	}
	
	public void xiaji(Wangmin min) {
		System.out.println("网民：" + min.getName() + "下机时间到：" + System.currentTimeMillis());
	}
	@Override
	public void run() {
		while(yinye) {
			try {
				Wangmin min = delayQueue.take();
				xiaji(min);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	
	public static void main(String[] args) {
		System.out.println("网吧开始营业...");
		WangBa wangBa = new WangBa();
		Thread shangwang = new Thread(wangBa);
		shangwang.start();
		wangBa.shangji("路人甲", "111", 1);
		wangBa.shangji("路人乙", "222", 10);
		wangBa.shangji("路人丙", "333", 5);
	}
}