Java中的BlockingDeque putFirst()方法及示例

putFirst(E e) 方法会在此双端队列队首插入指定元素。如果双端队列容量受限，则该方法将等待空间可用。

Syntax:

public void putFirst(E e)

参数： 此方法接受一个必填的参数 e ，该参数是要插入BlockingDeque前面的元素。

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

异常： 该程序会抛出以下两个异常：

• NullPointerException - 如果指定的元素为null
• InterruptedException - 如果等待时被中断

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

以下程序演示了 BlockingDeque 的 putFirst() 方法：

程序1：

// Java程序演示BlockingDeque的putFirst()方法
    
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.putFirst(7855642);
        BD.putFirst(35658786);
        BD.putFirst(5278367);
        BD.putFirst(74381793);
  
        // 打印Deque
        System.out.println("Blocking Deque: " + BD);
    }
}

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

程序2：

// Java程序演示在BlockingDeque中使用putFirst()方法时抛出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.putFirst(7855642);
        BD.putFirst(35658786);
        BD.putFirst(5278367);
  
        // 抛出异常
        BD.putFirst(null);
  
        // 打印Dequeue
        System.out.println("Blocking Deque: " + BD);
    }
}

输出：

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

程序3：

// Java Program Demonstrate putFirst()
// 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.putFirst(7855642);
        BD.putFirst(35658786);
        BD.putFirst(5278367);

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

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

输出: :

最大实时限制已超过，这可能是由于服务器负载过重或使用sleep函数所致

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