开发者

Java阻塞队列BlockingQueue基础与使用

开发者 https://www.devze.com 2023-01-04 10:34 出处:网络 作者: 欲无缘
目录什么是阻塞队列阻塞队列的特点blockingQueue不是新的东西学会使用队列SynchronousQueue 同步队列什么是阻塞队列
目录
  • 什么是阻塞队列
  • 阻塞队列的特点
  • blockingQueue不是新的东西
  • 学会使用队列
  • SynchronousQueue 同步队列

什么是阻塞队列

阻塞队列本质上还是一种队列,遵循先进先出,后进后出的原则,在此基础上,如果出队时阻塞队列为空,则会使当前线程陷入阻塞,直到入队新元素时通知线程继续执行,如果入队时阻塞队列为满,则会使当前线程陷入阻塞,直到出队旧元素时才通知线程进行执行。

阻塞队列的特点

Java阻塞队列BlockingQueue基础与使用

BlockingQueue不是新的东西

Java阻塞队列BlockingQueue基础与使用

学会使用队列

阻塞队列四组API

方式抛出异常有返回值编程,不抛出异常阻塞 等待超时等待
添加add(E e)offer(E e)put()offer(E e,Time,TimeUnit)
移除remove()poll()take()poll(Time,TimeUnit)
检测队首元素element()peek
  • 抛出异常是指当队列满时,再次插入会抛出异常(如果队列未满,插入返回值未true);
  • 返回布尔是指当队列满时,再次插入会返回false;
  • 阻塞是指当队列满时,再次插入会被阻塞,直到队列取出一个元素,才能插入。
  • 超时是指当一个时限过后,才会插入或者取出。

抛出异常

/**
* 抛出异常
*/
public static void test1(){
// 队列的大小
ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
System.out.println(blockingQueue.add("a"));
System.out.println(blockingQueue.add("b"));
System.out.println(blockingQueue.add("c"));
// IllegalStateException: Queu开发者_JAVA开发e full 抛出异常!
// System.out.println(blockingQueue.add("d"));
System.out.println(blockingQueue.removewww.devze.com());
System.out.println(blockingQueue.remove());
System.out.println(blockingQueue.remove());
// Java.util.NoSuchElementException 抛出异常!
// System.out.println(blockingQueue.remove());
}

有返回值,没有异

/**
* 有返回值,没有异常
*/
public static void test2(){
// 队列的大小
ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
System.out.println(blockingQueue.offer("a"));
System.out.println(blockingQueue.offer("b"));
System.out.println(blockingQueue.offer("c"));
// System.out.println(blockingQueue.offer("d")); // false 不抛出异常!
System.out.println(blockingQueue.poll());
System.out.println(blocking编程Queue.poll());
System.out.println(blockingQueue.poll());
System.out.println(blockingQueue.poll()); // null 不抛出异常!
}

等待,阻塞(一直阻塞)

/**
 * 等待,阻塞(一直阻塞)
 */
public static void test3() throws InterruptedException {
        // 队列的大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        // 一直阻塞
        blockingQueue.put("a");
        blockingQueue.put("b");
        blockingQueue.put("c");
        // blockingQueue.put("d"); // 队列没有位置了,一直阻塞
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take())
}

等待,阻塞(等待超时

/**
 * 等待,阻塞(等待超时)
 */
public static void test4() throws InterruptedException {
        // 队列的大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        blockingQueue.offer("a");
        blockingQueue.offer("b");
        blockingQueue.offer("c");
        // blockingQueue.offer("d",2,TimeUnit.SECONDS); // 等待超过2秒就退出
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        blockingQueue.poll(2,TimeUnit.SECONDS); 
}

SynchronousQueue 同步队列

和其他的BlockingQueue 不一样, SynchronousQueue 不存储元素

put了一个元素,必须从里面先take取出来,否则不能在put进去值!

public class SynchronousQueueDemo {
    public static void main(String[] args) {
        BlockingQueue<String> blockingQandroidueue = new SynchronousQueue<>(); // 同步队
        // new Thread(()->{
            try {
                System.out.println(Thread.currentThread().getName()+" put 1");
                blockingQueue.put("1");
                System.out.println(Thread.currentThread().getName()+" put 2");
                blockingQueue.put("2");
                System.out.println(Thread.currentThread().getName()+" put 3");
                blockingQueue.put("3");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"T1").start();
        new Thread(()->{
            try {
                TimeUnit.SECONDS.sleep(3);
                System.out.println(Thread.currentThread().getName()+"=>"+blockingQueue.take());
                TimeUnit.SECONDS.sleep(3);
                System.out.println(Thread.currentThread().getName()+"=>"+blockingQueue.take());
                TimeUnit.SECONDS.sleep(3);
                System.out.println(Thread.currentThread().getName()+"=>"+blockingQueue.take());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"T2").start();
    }
}

到此这篇关于Java阻塞队列BlockingQueue基础与使用的文章就介绍到这了,更多相关Java BlockingQueue内容请搜索我们以前的文章或继续浏javascript览下面的相关文章希望大家以后多多支持我们!

0

精彩评论

暂无评论...
验证码 换一张
取 消

关注公众号