Java中的BlockingDeque putLast()函数及示例

BlockingDeque 的 putLast(E e) 方法会将指定的元素插入到由此双端队列表示的队列末尾。如果双端队列具有容量限制，则它会等待空间可用。

语法：

public void putLast(E e)

参数： 此方法接受一个强制参数 e ，它是要插入到BlockingDeque末尾的元素。

返回值： 此方法不返回任何值。

异常： 程序会抛出如下两个异常：

• NullPointerException - 如果指定的元素为null。
• InterruptedException - 在等待期间中断。

注意： Java中的 BlockingDeque 的putLast()方法是从LinkedBlockingDeque类继承而来的。

下面的程序演示了BlockingDeque的putLast()方法：

程序1:

//Java程序演示BlockingDeque的putLast()方法

import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.BlockingDeque;
import java.util.*;

public class GFG {
    public static void main(String[] args)
        throws InterruptedException
    {

        //创建BlockingDeque的对象
        BlockingDeque<Integer> BD
            = new LinkedBlockingDeque<Integer>();

        //将数字添加到BlockingDeque的末尾
        BD.putLast(7855642);
        BD.putLast(35658786);
        BD.putLast(5278367);
        BD.putLast(74381793);

        //打印BlockingDeque
        System.out.println("Blocking Deque: " + BD);
    }
}

Blocking Deque: [7855642, 35658786, 5278367, 74381793]

程序2:

//Java程序演示BlockingDeque的putLast()方法
//抛出NullPointerException

import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.BlockingDeque;
import java.util.*;

public class GFG {
    public static void main(String[] args)
        throws InterruptedException
    {

        //创建BlockingDeque的对象
        BlockingDeque<Integer> BD
            = new LinkedBlockingDeque<Integer>();

        //将数字添加到BlockingDeque的末尾
        BD.putLast(7855642);
        BD.putLast(35658786);
        BD.putLast(5278367);

        //引发异常
        BD.putLast(null);

        //打印BlockingDeque
        System.out.println("Blocking Deque: " + BD);
    }
}

输出：

Exception in thread "main" java.lang.NullPointerException
    at java.util.concurrent.LinkedBlockingDeque.putLast(LinkedBlockingDeque.java:390)
    at GFG.main(GFG.java:24)

程序3:

// Java Program Demonstrate putLast()
// method of BlockingDeque
// when capacity exceeded

import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.BlockingDeque;
import java.util.*;

public class GFG {
    public static void main(String[] args)
        throws InterruptedException
    {

        // create object of BlockingDeque
        BlockingDeque<Integer> BD
            = new LinkedBlockingDeque<Integer>(3);

        // Add numbers to end of BlockingDeque
        BD.putLast(7855642);
        BD.putLast(35658786);
        BD.putLast(5278367);

        // throws an exception
        BD.putLast(4356789);

        // print Dequeue
        System.out.println("Blocking Deque: " + BD);
    }
}

输出 :

由于服务器负载过重或使用了sleep函数，实时限制已经超过最大值

参考: https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingDeque.html#putLast(E)