SynchronousQueue在java中的元素增减

本教程操作环境：windows7系统、java10版，DELL G3电脑。

1.方法介绍

put(E e) 添加一个非空元素，同时会阻塞住，直到另一个线程调用take()

take() 取出一个元素，如果队列为空，阻塞，直到另一个线程调用put(E e)

2.入队put方法实例

public void put(E e) throws InterruptedException {  
    if (e == null) throw new NullPointerException();// 元素不可为null
    // 三个参数分别是：传输的元素，是否需要超时，超时的时间
    if (transferer.transfer(e, false, 0) == null) {
        // 如果传输失败，直接让线程中断并抛出中断异常
        Thread.interrupted();
        throw new InterruptedException();
    }
}

3.出队take方法实例

public E take() throws InterruptedException {
    E e = transferer.transfer(null, false, 0);
    if (e != null)
        return e;
    Thread.interrupted();
    throw new InterruptedException();
}