并发编程-Concurren线程安全的容器

以你之姓@ 2022-02-22 12:44 286阅读 0赞

## ConcurrentMap ##

最多分16段（细粒度，减少锁的力度，减小锁竞争）

ConcurrentHashMap（无序map）

ConcurrentSkipListMap(有序map)

## Copy-On-Write ##

写时复制，完成后把指针指向新容器（应用场景，读多写少）。内部加锁，多个写后一个会等待第一个执行完成。

copyonwritearraylist

copyonwritearrayset

## Queue ##

ConcurrentLinkedQueue

高性能队列（生成者小于消费者），无界，不阻塞，先进先出

无锁的方式

头是最先加入的，尾是最近加入的，该队列不允许null元素。

ConcurrentLinkedDeque q = new ConcurrentLinkedDeque();
    	q.offer("方法1");
    	q.offer("码云1");
    	q.offer("方法2");
    	q.offer("方法3");
    	q.offer("码云2");
    	//从头获取元素,删除该元素
    	System.out.println(q.poll());
    	//从头获取元素,不刪除该元素
    	System.out.println(q.peek());
    	//获取总长度
    	System.out.println(q.size());

BlockingQueue 阻塞队列

被阻塞的2种情况

1. 当队列满了的时候进行入队列操作，被柱塞

2. 当队列空了的时候进行出队列操作，被柱塞

（可以设置2秒内加入，加入不了返回false，通过drainTo把队列里的3个元素放入集合内）

ArrayBlockingQueue：是一个有边界的阻塞队列，它的内部实现是一个数组（先进先出）

<String> arrays = new ArrayBlockingQueue<String>(3);
    	arrays.add("添加");
    	 arrays.add("添加");
    	arrays.add("添加");
    	// 添加阻塞队列
    	arrays.offer("张三", 1, TimeUnit.SECONDS);

linkedblockingqueue：无界（不设置范围情况下是Integer.MAX\_VALUE）阻塞队列（也是可以设置范围大小）先进先出

LinkedBlockingQueue linkedBlockingQueue = new LinkedBlockingQueue(3);
    linkedBlockingQueue.add("张三");
    linkedBlockingQueue.add("李四");
    linkedBlockingQueue.add("李四");
    System.out.println(linkedBlockingQueue.size());

priorityBlockingQueue：按照固定排序，优先级最高的先执行（没有边界）

允许插入null对象

PriorityBlockingQueue的对象必须实现 java.lang.Comparable接口

[https://www.cnblogs.com/WangHaiMing/p/8798709.html][https_www.cnblogs.com_WangHaiMing_p_8798709.html]

delayqueue：内部数据，可以设置延迟多秒后才能获取

synchronousqueue：没有空间，必须拿到立刻使用

队列内部仅允许容纳一个元素

[https_www.cnblogs.com_WangHaiMing_p_8798709.html]: https://www.cnblogs.com/WangHaiMing/p/8798709.html