首页 > 文章列表 > SynchronousQueue在java中的元素增减

SynchronousQueue在java中的元素增减

java SynchronousQueue
486 2022-08-06

本教程操作环境: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();
}