Java多线程（7）：JUC（下）

待我称王封你为后i 2023-10-03 21:16 8阅读 0赞

![format_png][]

您好，我是湘王，这是我的掘金小站，欢迎您来，欢迎您再来～

除了四种常见的同步器（发令枪、摇号器、栅栏和交换机），JUC还有所谓线程安全的容器、阻塞队列和一些特殊的类。其中常出现的就是线程安全的容器和阻塞队列。与其说这是两个大的分类，还不如说它就是两个用得最多的类：ConcurrentHashMap和ArrayBlockingQueue。

我的风格是尽量少讲原理，多讲实际生活中的案例，除非它非常重要，就像AQS，这玩意绝对是个重量级的神器，差不多整个JUC都是建立在它之上的。如果说学习多线程只有一次集中全部精力的机会的话，那我绝对建议把这份宝贵的精力花在AQS上，物超所值。至于搞明白ThreadPool底层原理、synchronized关键字原理，个人认为纯属浪费时间。因为即使弄明白了，那个机制你是改不了的，而AQS原理弄明白了，可以直接拿来用，自己玩出花来。

从之前的集合类继承结构图可以知道，ConcurrentHashMap继承自Map，实现了ConcurrentMap接口，它是线程安全的Map，侧重于放入或者获取的速度，而不在乎顺序。

因为现在的Java基本上都升级到了JDK1.8以上，有的甚至和官方保持同步，所以基本上很多JDK1.7及以下会出现的问题，在新的版本中都修复了，而且性能越来越好。所以只需要知道一点：在并发量比较高的环境中尽量使用ConcurrentHashMap就好了。不用弄明白为什么，因为不值得（JDK1.8的ConcurrentHashMap底层是用红黑树实现的，至于什么是红黑树，又得回头补一些基础，而且记住了也没啥用）。当然如果是为了应付面试，稍稍了解一下就好了。

ArrayBlockingQueue和LinkedBlockingQueue在之前的线程池ThreadPool中也提过，它们的共同点都是一边放一边拿，唯一的不同是一个是数量有限的，一个是数量无限的。

![format_png 1][]

之前拿上菜的案例演示了ArrayBlockingQueue，现在同样的案例再用LinkedBlockingQueue来实现：

/**
     * LinkedBlockingQueue测试
     *
     * @author 湘王
     */
    public class LinkedBlockingQueueTester {
       public static BlockingQueue<String> queue = new LinkedBlockingQueue<String>(5);
       // 一个往里放
       class Producer implements Runnable {
          @Override
          public void run() {
             try {
                queue.offer("川菜");
                System.out.println(Thread.currentThread().getName() + " 厨师做好 川菜");
             } catch (Exception e) {
                e.printStackTrace();
             }
          }
       }
       // 一个往外拿
       class Consumer implements Runnable {
          @Override
          public void run() {
             try {
                String food = queue.poll();
                System.out.println(Thread.currentThread().getName() + " 客人消费 " + food);
             } catch (Exception e) {
                e.printStackTrace();
             }
          }
       }
       public static void main(String[] args) {
          // 和ArrayBlockingQueue不讲究顺序不同，LinkedBlockingQueue需要将生产的一方放在前面
          // 厨师做好菜
          for (int i = 0; i < 5; i++) {
             new Thread(new LinkedBlockingQueueTester().new Producer()).start();
          }
          // 客人等着菜
          for (int i = 0; i < 5; i++) {
             new Thread(new LinkedBlockingQueueTester().new Consumer()).start();
          }
       }
    }
    复制代码

JUC中一些其他的类，例如ForkJoinPool，可以把任务分解成更小的任务，被分解出来任务会被继续分解成更小的任务，更形象地说法是“分形器”。而RecursiveTask是一种会返回结果的任务，它可以将自己分解成若干更小的任务，并将这些任务的执行结果合并到一个结果里。这两种用的不多。

整个JUC里面最重要的还是前面3种共6个Java类，掌握好AQS和这6个常见类，JUC基本就没啥问题了。

感谢您的大驾光临！咨询技术、产品、运营和管理相关问题，请关注后留言。欢迎骚扰，不胜荣幸～

[format_png]: https://img-blog.csdnimg.cn/img_convert/a599545f644680b8d82f64814fac616a.webp?x-oss-process=image/format,png
[format_png 1]: https://img-blog.csdnimg.cn/img_convert/a0f5f7cf4f8ad59813ffeb015586d936.webp?x-oss-process=image/format,png