Catalog

3 Yes API Conclusion

Put in test

Take out the test

3 Yes API Conclusion

Put in test

public static void main(String[] args) throws Exception {
       new Thread(() -> {
            BlockingQueue<String> queue = new LinkedBlockingQueue<>(1);
            try {
                queue.put("1");
                queue.put("1"); // Blocking when full 
                System.out.println(" Don't print me ");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();

        new Thread(() -> {
            BlockingQueue<String> queue = new LinkedBlockingQueue<>(1);
            System.out.println("offer1"+queue.offer("1"));
            System.out.println("offer2"+queue.offer("1"));// Return when full false
        }).start();

        new Thread(() -> {
            BlockingQueue<String> queue = new LinkedBlockingQueue<>(1);
            System.out.println("add1"+queue.add("1"));
            System.out.println("add2"+queue.add("1"));// Abnormal when full 
        }).start();


       
    }

offer1true
offer2false
add1true
Exception in thread "Thread-2" java.lang.IllegalStateException: Queue full
    at java.util.AbstractQueue.add(AbstractQueue.java:98)
    at com.construn.vehicle.common.core.monitor.App.lambda$main$2(App.java:30)
    at com.construn.vehicle.common.core.monitor.App$$Lambda$3/1982791261.run(Unknown Source)
    at java.lang.Thread.run(Thread.java:745)

public static void main(String[] args) throws Exception {

         new Thread(() -> {
            BlockingQueue<String> queue = new LinkedBlockingQueue<>(Lists.newArrayList("AAA"));
            try {
                System.out.println("take1"+queue.take());
                System.out.println("take2"+queue.take()); // Space time blocking 
                System.out.println(" Don't print me ");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();

        new Thread(() -> {
            BlockingQueue<String> queue = new LinkedBlockingQueue<>(Lists.newArrayList("AAA"));
            System.out.println("poll1"+queue.poll());
            System.out.println("poll2"+queue.poll());// Empty time returns null
        }).start();

        new Thread(() -> {
            BlockingQueue<String> queue = new LinkedBlockingQueue<>(Lists.newArrayList("AAA"));
            System.out.println("remove1"+queue.remove());
            System.out.println("remove2"+queue.remove());// Space time exception 
        }).start();




    }

remove1AAA
poll1AAA
poll2null
take1AAA
Exception in thread "Thread-2" java.util.NoSuchElementException
    at java.util.AbstractQueue.remove(AbstractQueue.java:117)
    at com.construn.vehicle.common.core.monitor.App.lambda$main$2(App.java:54)
    at com.construn.vehicle.common.core.monitor.App$$Lambda$3/1982791261.run(Unknown Source)
    at java.lang.Thread.run(Thread.java:745)