JUC（二）JAVA线程池开启，等待全部执行完毕，配合计数器使用，List并发异常解决

前言

• 日常写代码过程中&＃xff0c;我经常会有一些处理很多数据的业务&＃xff0c;如一些定时任务&＃xff0c;需要用到线程池

1.定义一个线程池

ThreadPoolExecutor poolExecutor &＃61; new ThreadPoolExecutor(2,Runtime.getRuntime().availableProcessors(),//这里我获取的物理机的核心线程数2,TimeUnit.MILLISECONDS,new LinkedBlockingQueue<>(10),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());


1.1线程池七大参数

1. corePoolSize 核心线程数目 - 池中会保留的最多线程数
2. maximumPoolSize 最大线程数目 - 核心线程&＃43;救急线程的最大数目
3. keepAliveTime 生存时间 - 救急线程的生存时间&＃xff0c;生存时间内没有新任务&＃xff0c;此线程资源会释放
4. unit 时间单位 - 救急线程的生存时间单位&＃xff0c;如秒、毫秒等
5. workQueue - 当没有空闲核心线程时&＃xff0c;新来任务会加入到此队列排队&＃xff0c;队列满会创建救急线程执行任务
6. threadFactory 线程工厂 - 可以定制线程对象的创建&＃xff0c;例如设置线程名字、是否是守护线程等
7. handler 拒绝策略 - 当所有线程都在繁忙&＃xff0c;workQueue 也放满时&＃xff0c;会触发拒绝策略
   1 抛异常 java.util.concurrent.ThreadPoolExecutor.AbortPolicy
   2 由调用者执行任务 java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy
   3 丢弃任务 java.util.concurrent.ThreadPoolExecutor.DiscardPolicy
   4 丢弃最早排队任务 java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy

1.2使用线程池(1.配合CompletableFuture.supplyAsync()使用)

List<Integer> list &＃61; new CopyOnWriteArrayList();Data data &＃61; new Data();for (int i &＃61; 0; i < 3000; i&＃43;&＃43;) {CompletableFuture<Integer> supplyAsync &＃61; CompletableFuture.supplyAsync(() -> {try {System.out.println(Thread.currentThread().getName());return data.getData();} catch (InterruptedException e) {e.printStackTrace();}return 1;},poolExecutor);try {list.add(supplyAsync.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}
}
poolExecutor.shutdown();


1.2.1 CopyOnWriteArrayList

• CopyOnWriteArrayList类最大的特点就是&＃xff0c;在对其实例进行修改操作&＃xff08;add/remove等&＃xff09;会新建一个数据并修改&＃xff0c;修改完毕之后&＃xff0c;再将原来的引用指向新的数组。这样&＃xff0c;修改过程没有修改原来的数组。也就没有了ConcurrentModificationException错误。
• 

1.3使用线程池(2.配合CountDownLatch()使用)

List<String> list &＃61; new ArrayList<>();
list.add("test1");
list.add("test2");
list.add("test3");
list.add("test4");
list.add("test5");
CountDownLatch countDownLatch &＃61; new CountDownLatch(list.size());ExecutorService threadPool &＃61; new ThreadPoolExecutor(2,Runtime.getRuntime().availableProcessors(),3,TimeUnit.SECONDS,new LinkedBlockingQueue<>(3),Executors.defaultThreadFactory(),new ThreadPoolExecutor.CallerRunsPolicy());//四种拒绝策略try {for (String s : list) {threadPool.execute(() -> {try {System.out.println(Thread.currentThread().getName() &＃43; " --------------ok");} catch (Exception e) {e.printStackTrace();} finally {countDownLatch.countDown(); //-1}});}
} catch (Exception e) {e.printStackTrace();
} finally {countDownLatch.await();//线程池用完 程序结束, 关闭线程池threadPool.shutdown();
}


• countDownLatch.await(); 等待计数器归零

总结

• CPU密集型任务(N&＃43;1)&＃xff1a;这种任务消耗的主要是CPU资源&＃xff0c;可以将线程数设置为N(CPU核心数)&＃43;1&＃xff0c;比CPU核心数多出来一个线程是为了防止线程偶发的缺页中断&＃xff0c;或者其他原因导致的任务暂停而带来的影响。一旦任务停止&＃xff0c;CPU就会处于空闲状态&＃xff0c;而这种情况下多出来一个线程就可以充分利用CPU的空闲时间
• I/O密集型(2N)&＃xff1a;这种任务应用起来&＃xff0c;系统大部分时间用来处理I/O交互&＃xff0c;而线程在处理I/O的是时间段内不会占用CPU来处理&＃xff0c;这时就可以将CPU交出给其他线程使用。因此在I/O密集型任务的应用中&＃xff0c;可以配置多一些线程&＃xff0c;具体计算方是2N。