Java语言提供了java.util.concurrent包解决线程同步问题，concurrent包中的阻塞队列BlockingQueue能够很好地线程同步问题，
接口BlockingQueue提供如下几个线程同步方法
保存数据：
offer(obj):向队列BlockingQueue保存数据,如果BlockingQueue可以容纳,返回true,否则返回false.方法立刻返回不阻塞线程。
offer(E o, long timeout, TimeUnit unit),设定保存数据的等待时间，如果在指定的时间内，还不能向BlockingQueue保存数据，则返回失败。
put(obj):把obj加到BlockingQueue里,如果BlockQueue没有空间,阻断调用线程，一直等到到BlockingQueue里面有空间再恢复执行。
取得数据：
poll(time):从对列BlockingQueue首位取对象,如果队列为空等待time参数规定的时间,取不到数据返回null;
poll(long timeout, TimeUnit unit)：从对列BlockingQueue首位取对象，等待设定时间，如果取不到数据返回null;
take():从对列BlockingQueue首位取对象,如果队列为空一直等到数据直到队列中有数据;
drainTo():一次从BlockingQueue获取所有可用的数据对象、可以提升获取数据效率。
BlockingQueue实现类
ArrayBlockingQueue，LinkedBlockingQueue
ArrayBlockingQueue使用数组存取数据，生产者线程和消费者线程共享同一对象，它们不可以同时在对象加同步锁，这与LinkedBlockingQueue不同，LinkedBlockingQueue使用链表存储，生产者线程和消费者线程可以同时拥有对立的锁，同时操作LinkedBlockingQueue队列；ArrayBlockingQueue队列有长度，而LinkedBlockingQueue队列的长度是Integer.MAX_VALUE，当生产者线程快于消费者线程时可能导致内存溢出；在队列中添加，删除和插入对象时ArrayBlockingQueue不产生临时对象，LinkedBlockingQueue生成额外的Node对象，这与可能导致GC压力。
代码