JUC（5）BlockingQueue四组API

package com.readlock;

import java.util.HashMap;
import java.util.Map;


public class ReadWriteLockDemo {
    public static void main(String[] args) {
        MyCache myCache = new MyCache();

        for (int i = 0; i < 5; i++) {
            final int temp = i;
            new Thread(()->{
              myCache.put(temp+"",temp+"");//写入
            },String.valueOf(i)).start();

        }

        for (int i = 0; i < 5; i++) {
            final int temp = i;
            new Thread(()->{
                myCache.get(temp+"");//读取
            },String.valueOf(i)).start();

        }


    }

}

class MyCache{
    private volatile Map map =new HashMap<>();


    //写
    public void put(String key,Object value){
        System.out.println(Thread.currentThread().getName()+"写入"+key);
        map.put(key,value);
        System.out.println(Thread.currentThread().getName()+"写入成功");

    }

    //读
    public void get(String key){
        System.out.println(Thread.currentThread().getName()+"读取"+key);
        Object o = map.get(key);
        System.out.println(Thread.currentThread().getName()+"读取成功");

    }
}

测试结果（正常情况下：写入、写入成功）

• 写入：如果队列满了，就必须阻塞等待
• 取：如果是队列是空的，必须阻塞等待产生

BlockingQueue
什么情况下我们会使用阻塞队列：多线程并发处理，线程池！

学会使用队列
添加、移除

1、抛出异常

• 2、不会抛出异常
• 3、阻塞、等待
• 4、超时等待

add 和remove会抛出异常。队列满继续添加数据到队列，队列空，继续取出元素

package com.blockingqueue;

import java.util.concurrent.ArrayBlockingQueue;

public class BlockingQueueDemo {
    public static void main(String[] args) {
        test1();
    }

    
    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"));

        
        System.out.println("===========================");
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());

        
        

    }
}

查看队首元素

off 和 poll

使用offer不抛出异常

使用poll、源码

put 和 take

如果队列满了、设置超时时间、当过了这个超时时间，自动退出