大家好，我是哪吒。
上一章提到了一个关于 i++ 和 ++i 的面试题打趴了所有人，最终方案是在两个方法上添加synchronized关键字，从而避免i++的线程安全问题，不过，这样真的好吗？在所有有线程安全的方法都添加synchronized？
答案是显而易见的，不行。
synchronized会极大的降低程序的性能，导致整个程序几乎只能支持单线程操作，性能显著降低。
那么，如何解决呢？
锁的粒度更小了，也解决了这个问题，确实可以的。
package com.guor.thread;public class SynchronizedTest2 { int a = 1; int b = 1; public void add() { System.out.println("add start"); synchronized (this) { for (int i = 0; i < 10000; i++) { a++; b++; } } System.out.println("add end"); } public synchronized void compare() { System.out.println("compare start"); synchronized (this) { for (int i = 0; i < 10000; i++) { boolean flag = a < b; if (flag) { System.out.println("a=" + a + ",b=" + b + "flag=" + flag + ",a < b = " + (a < b)); } } } System.out.println("compare end"); } public static void main(String[] args) { SynchronizedTest2 synchronizedTest = new SynchronizedTest2(); new Thread(() -> synchronizedTest.add()).start(); new Thread(() -> synchronizedTest.compare()).start(); }}为了更好的优化，有的时候可以将synchronized代码块变为区分读写场景的读写锁，也可以考虑悲观锁和乐观锁的区分。
对于读写场景比较多的情况，可以使用ReentrantReadWriteLock区分读写，再次降低锁的粒度，提高程序的性能。
ReentrantReadWriteLock 还可以选择提供了公平锁，在没有明确必须使用公平锁的情况下，尽量不要使用公平锁，公平锁会使程序性能降低很多很多。
简单来说，公平锁（谁先排队，谁先执行），非公平锁（不用排队，每个人都有机会）。
有一天早上，云韵、美杜莎、小医仙结伴去买酱香拿铁，到了咖啡店，先排队，一个一个来。不一会，哪吒来了，也买酱香拿铁，只能在末尾排队。这个就是公平锁。
但是呢？第二天早上，哪吒又去买酱香拿铁，上一次去晚了没买到（线程被饿死了），这次急了，要插队买，不讲武德。终于喝上了心心念念的酱香拿铁，这个就是非公平锁。
我们都知道，静态字段属于类，类级别的锁才能保护；非静态字段属于类实例，实例级别的锁才能保护。
先看一下下面的代码：
import lombok.Data;import java.util.stream.IntStream;@Datapublic class LockTest { public static void main(String[] args) { IntStream.rangeClosed(1, 100000).parallel().forEach(i -> new LockTest().increase()); System.out.println(time); } private static int time = 0; public synchronized void increase() { time++; }}在LockTest类中定义一个静态变量time，定义一个非静态方法increase()，实现time++自增。先累加10万次，测试一下。看看是否有线程安全的问题。
这...不对啊，上一节在介绍高并发下i++线程安全问题的时候，synchronized 是好使的啊。
今天这是怎么了？再运行一次，结果依然如此，不等于100000
先来分析一下。
在非静态的方法上加synchronized，只能确保多个线程无法执行同一个实例的increase()方法，却不能保证不同实例的increase()方法。静态的变量time，在多个线程中共享，所以会出现线程安全的问题，synchronized失效了。
那么，将synchronized改为静态方法是不是就可以了，试一下。
有两种写法，一种是直接将方法改为静态方法，一种是使用synchronized代码块。
private static Object obj= new Object();public void increase() { synchronized (obj) { time++; }}
很多小伙伴，可能会好奇，这个是干什么的，干了5年后端代码开发了，没见过这玩意儿。
IntStream是一种特殊的stream，用来提供对int相关的stream操作。
IntStream.rangeClosed：生成某个数字范围内的数字集合的stream。
比如上面代码中的IntStream.rangeClosed(1, 100000).parallel().forEach(i -> new LockTest().increase());。
Stream.parallel() 方法是 Java 8 中 Stream API 提供的一种并行处理方式。在处理大量数据或者耗时操作时，使用 Stream.parallel() 方法可以充分利用多核 CPU 的优势，提高程序的性能。
Stream.parallel() 方法是将串行流转化为并行流的方法。通过该方法可以将大量数据划分为多个子任务交由多个线程并行处理，最终将各个子任务的计算结果合并得到最终结果。使用 Stream.parallel() 可以简化多线程编程，减少开发难度。
需要注意的是，并行处理可能会引入线程安全等问题，需要根据具体情况进行选择。
定义一个list，然后通过parallel() 方法将集合转化为并行流，对每个元素进行i++，最后通过 collect(Collectors.toList()) 方法将结果转化为 List 集合。
使用并行处理可以充分利用多核 CPU 的优势，加快处理速度。
public class StreamTest { public static void main(String[] args) { List<Integer> list = new ArrayList<>(); for (int i = 0; i < 10; i++) { list.add(i); } System.out.println(list); List<Integer> result = list.stream().parallel().map(i -> i++).collect(Collectors.toList()); System.out.println(result); }}我勒个去，什么情况？
这是大部分开发人员都会犯的小错误，在上篇中提到过，i++ 返回原来的值，++i 返回加1后的值。这谁都知道，可是，写的时候，就不一定了，因为你习惯了i++，写顺手了，写的时候也是心不在焉，一蹴而就了。
i++改了++i即可。
优点：
缺点：
在实际开发中，应该根据数据量、计算复杂度、硬件等因素综合考虑。
比如：
本文链接：http://www.28at.com/showinfo-26-12358-0.html简单聊一聊公平锁和非公平锁，Parallel并行流
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
上一篇： 你真的理解Python Qt6基础知识中的信号和槽机制吗？
下一篇： 有了这个代码模板，合并排序手到擒来
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号
