搜索到
211
篇与
的结果
-
去掉IDEA 警告：Raw use of parameterized class ‘xxx’ 作为一个精致的代码主义者，是绝对不允许IDE里面出现各种屎黄色的警告信息的。比如Raw use of parameterized class xxx，当然出现这种警告有两种可能，一种是我们没有正确使用泛型，这种就比较好解决了正确使用即可，另外一种就比较膈应人，可能是调用别人的方法。一、对象带上具体的泛型 (推荐)这种就比较好理解了，好比我们相面New一个Map,我们只需要正确使用泛型即可。二、在方法上加注解这种就属于比较隔应的了，如果是调用别人的方法，要么强制转换，要么直接用，结果就是出现屎黄色的波浪线。这种方法就只能退而求其次，屏蔽到IDEA的提示，我们可以在方法上下面的注解 @SuppressWarnings({"rawtypes"}) -
Jackson反序列化时忽略某些属性的方法 在开发接口时，出于某些目的（比如有些字段我要设置默认值，不能受入参的影响），我们在入参字符串序列化成实体时，可能需要忽略某些属性。我们要达到的目的非常简单，一个用户类User.java，我们要达到的目的有两个：（1）控制序列化时，忽略name属性。（2）控制反序列化是，忽略name属性。一、@JsonIgnore注解当我们想控制是一个实体在序列化时，忽略某些属性，我们第一个想到的也许就是@JsonIgnore注解了，@JsonIgnore注解能控制实体在序列化时，忽略某些属性，但是无法控制实体在反序列化时忽略的属性。先来看一下我们测试用的User.java类。public class User implements Serializable { private String code; @JsonIgnore private String name; public String getCode() { return code; } public void setCode(String code) { this.code = code; } public String getName() { return name; } public void setName(String name) { this.name = name; } }1.1、序列化我们先试一下序列化，看看name属性能否在序列化时自动忽略掉。测试方法也非常简单ObjectMapper objectMapper = new ObjectMapper(); User user = new User(); user.setCode("code123"); user.setName("name123"); System.out.println(objectMapper.writeValueAsString(user));可以看到，name属性确实忽略了，也就是这个注解针对序列化是生效的。1.2、反序列化序列化时候没问题，那么反序列化时候是否也没问题呢，我们接着往下看。String userStr = "{\"code\":\"code123\",\"name\":\"name123\"}"; User user1 = objectMapper.readValue(userStr, User.class);这个时候我们不能在序列化输出显示了，我们调试看一下。我们可以看到，也是能够正常忽略掉的。但是，今天在项目开发时，我使用了同样的方法，发现@JsonIgnore注解没有起作用，但是实体类是这么样的@Data @NoArgsConstructor public class User implements Serializable { private String code; @JsonProperty(value = "name") @JsonIgnore private String name; @JsonProperty(value = "billCateProp") @JsonIgnore @JSONField(deserialize = false) private String billCateProp; @JsonFormat(pattern = "yyyy-MM-dd") private Date date; }怀疑了Data注解，也怀疑了@JsonProperty与@JsonIgnore注解冲突，甚至是属性Camel命名等，但是同样的代码，我拿到别的地方也有没有再现问题，所以终究也不知道是什么原因导致的。2、@JsonProperty@JsonIgnore的问题没有解决，只能另辟蹊径，最终发现@JsonIgnore注解有个access属性，通过access属性解决了问题，在反序列化时，不会再读取忽略的字段，遂将代码调整如下 @JsonProperty(value = "billCateProp",access = JsonProperty.Access.READ_ONLY) // @JsonIgnore @JSONField(deserialize = false) private String billCateProp;JsonProperty.Access.READ_ONLY代表反序列化是忽略字段。JsonProperty.Access.WRITE_ONLY代表序列化时忽略字段。@JsonIgnore失效的问题，最终也没找到答案，有知道的童鞋不妨留言说明一下。
-
使用CompletableFuture<T>实现异步接口 【同步API】同步API是我们传统方法，调用方法在被调用方法运行的过程中会一直等待，直到被调用方法返回。此时的调用过程，是阻塞式的调用。【异步API】与同步API相反，异步API会直接返回，或者至少在被调用方计算完成之前，将它剩余的计算任务交给另外一个线程去做，该线程和调用方是异步的，是非阻塞式调用。来看一下【同步API】与【异步API】的区别 public class Shop { public double getPrice(String product) { return calculatePrice(product); } public Future<Double> getPriceAsync(String product) { CompletableFuture<Double> futurePrice = new CompletableFuture<>(); new Thread(() -> { double price = calculatePrice(product); futurePrice.complete(price); }).start(); return futurePrice; } private double calculatePrice(String product) { delay(); return new Random().nextDouble() * product.charAt(0) * product.charAt(1); } public static void delay() { try { Thread.sleep(1000L); } catch (InterruptedException interruptedException) { throw new RuntimeException(interruptedException); } } } 在上面的代码中，getPrice()是一个同步方法，其内部调用的calculatePrice()用于模拟价格计算，计算过程中，暂停线程1s用于模拟阻塞。然后我们调用getPrice()，查看程序执行时间。 public class Main { public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException { Shop shop = new Shop(); long startTime = System.currentTimeMillis(); double doubleFuture = shop.getPrice("apple"); doSomeThingElse(); long endTime = System.currentTimeMillis(); System.out.println("总耗时：" + (endTime - startTime) + "ms"); } private static void doSomeThingElse(){ try { Thread.sleep(2000L); } catch (InterruptedException e) { e.printStackTrace(); } } } 此时查看控制台，我们可以看到共执行了3011ms，也就是说，此时整个程序是串行的。此时我们再来看看另一个方法getPriceAsync(),此方法不再返回double类型，而是一个Future<Double>，Future<T>接口标识一个异步计算的结果，泛型代表返回值。Future的计算结果，通过get()方法获取。在getPriceAsync()方法中，我们创建了一个代表异步计算的CompletableFuture<T>，它在计算完成后，会包含计算的结果。接着创建一个线程去执行实际的操作，不必等到线程结束，直接返回一个Future<Double>实例。当线程计算结束后，调用CompletableFuture<T>的complete()方法，结束CompletableFuture<T>的运行。然后我们调用getPriceAsync()方法，查看程序执行时间。public class Main { public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException { Shop shop = new Shop(); long startTime = System.currentTimeMillis(); Future<Double> doubleFuture = shop.getPriceAsync("apple"); doSomeThingElse(); doubleFuture.get(2, TimeUnit.SECONDS); long endTime = System.currentTimeMillis(); System.out.println("总耗时：" + (endTime - startTime) + "ms"); } private static void doSomeThingElse(){ try { Thread.sleep(2000L); } catch (InterruptedException e) { e.printStackTrace(); } } }此时查看控制台，可以看到总体耗时2108ms，也就是说我们主程序跟getPriceAsync()方法此时是并行的了。【改进的异步方法】在前面的getPriceAsync()方法中，我们创建了一个线程创建CompletableFuture<T>对象，实际上，还有一种更简便的方式，即使用工厂方法CompletableFuture.supplyAsync创建CompletableFuture<T>对象。改进后的代码如下所示 public Future<Double> getPriceAsync(String product) { // CompletableFuture<Double> futurePrice = new CompletableFuture<>(); // new Thread(() -> { // double price = calculatePrice(product); // futurePrice.complete(price); // }).start(); // return futurePrice; return CompletableFuture.supplyAsync(()-> calculatePrice(product)); }
-
Java BigDecimal Non-terminating decimal expansion; no exact representable decimal result 在日常开发中，我们基本上都是用BigDecimal类型来处理金额，防止精度丢失。使用BigDecimal做除法时，如果出现除不尽的情况，系统就会报错之所以出现这个问题，是因为除法除不尽时，BigDecimal不知道如何处理了，因此，使用BigDecimal做除法时，我们需要指定结果的精度及四舍五入的方式。BigDecimal bigDecimalThree = new BigDecimal("3"); BigDecimal newBigDecimal = BigDecimal.ONE.divide(bigDecimalThree, 1, RoundingMode.HALF_EVEN); System.out.println(newBigDecimal);
-
java8函数式接口注解FunctionalInterface 函数式接口就是为Java 8的Lambda表达式准备的，Java 8允许使用Lambda表达式创建函数式接口的实例，因此Java 8 专门增加了@FunctionalInterface。什么是函数式接口我们提到如果接口中只有一个抽象方法（可以包含多个默认方法或多个 static 方法），那么该接口就是函数式接口。FunctionalInterface作用@FunctionalInterface就是用来指定某个接口必须是函数式接口，所以@FunInterface只能修饰接口，不能修饰其它程序元素。看下一下面的方法@FunctionalInterface public interface BufferedReaderProcessor { /** * 静态方法 */ static void process() { System.out.println("process"); } /** * 抽象方法 * * @param bufferedReader * @return * @throws IOException */ String process(BufferedReader bufferedReader) throws IOException; /** * 默认方法 * * @param bufferedReader * @return * @throws IOException */ default String process1(BufferedReader bufferedReader) throws IOException { return ""; } }此时IDE是没有任何错误的（当然代码没有错误）截止到此时，我们出程序中的@FunctionalInterface一丢丢的作用，其实@FunctionalInterface注解的作用只是告诉IDE检查这个接口，保证该接口只能包含一个抽象方法，否则就会编译出错。如何理解一个抽象方法的含义。是否能只不包含抽象方法？我们继续修改刚才的代码，注释掉唯一的一个抽象方法 @FunctionalInterface public interface BufferedReaderProcessor { /** * 静态方法 */ static void process() { System.out.println("process"); } // /** // * 抽象方法 // * // * @param bufferedReader // * @return // * @throws IOException // */ // String process(BufferedReader bufferedReader) throws IOException; /** * 默认方法 * * @param bufferedReader * @return * @throws IOException */ default String process1(BufferedReader bufferedReader) throws IOException { return ""; } }此时，IDE给了错误提示了：No target method found（没有找到目标方法），也就是说，一旦使用@FunctionalInterface注解接口，我们必须要提供一个抽象方法。是否能提供多个抽象方法？刚刚我们看到了，一旦接口@FunctionalInterface，我们接口必须包含抽象方法，那么是否能包含多个抽象方法呢，我们看下面代码。@FunctionalInterface public interface BufferedReaderProcessor { /** * 静态方法 */ static void process() { System.out.println("process"); } /** * 抽象方法 * * @param bufferedReader * @return * @throws IOException */ String process(BufferedReader bufferedReader) throws IOException; /** * 抽象方法 * * @return */ String process1(); /** * 默认方法 * * @param bufferedReader * @return * @throws IOException */ default String process1(BufferedReader bufferedReader) throws IOException { return ""; } }此时ide提示Multiple non-overriding abstract methods found in XXX（找到多个非重载的抽象方法），也就是说，一个接口一旦注解了@FunctionalInterface就只能有一个抽象方法。
-
java同步锁Lock 在Java中Synchronized的用法中，我们介绍了通过Synchronized实现线程同步的机制。除了通过Synchronized实现线程同步之外，我们还可以通过同步锁（java.util.concurrent.locks.Lock）实现线程同步。看下下面代码package com.company.threadpackage; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class Apple implements Runnable { private int num = 50; private final Lock lock = new ReentrantLock(); @Override public void run() { while (num > 0) { lock.lock(); try { if (num > 0) { System.out.println(Thread.currentThread().getName() + " 吃了编号为 " + num-- + " 的苹果"); } }finally { lock.unlock(); } } } }调用 Apple apple = new Apple(); for(int i=0;i<1000;i++){ new Thread(apple,"apple"+i).start(); } 查看控制台，可以看到，num始终是在顺序减少。Lock 接口的实现允许锁在不同的作用范围内获取和释放，并允许以任何顺序获取和释放多个锁。常用的实现类ReentrantLock（可重入锁）：java.util.concurrent.locks 包中，通常建议使用 finally 块来确保在必要时释放锁ReentrantLock 是可重入锁：当前持有该锁的线程能够多次获取该锁，无需等待（可以在递归算法中使用锁）[typing]Lock 和 synchronized 的选择[/typing]Lock是一个接口，而synchronized是Java中的关键字，synchronized是内置的语言实现synchronized在发生异常时，会自动释放线程占有的锁，因此不会导致死锁现象发生；而Lock在发生异常时，如果没有主动通过unLock 去释放锁，则很可能造成死锁现象，因此使用Lock时需要在finally块中释放锁Lock可以让等待锁的线程响应中断，而synchronized却不行，使用synchronized时，等待的线程会直等待下去，不能够响应中断通过Lock可以知道有没有成功获取锁，而synchronized却无法办到Lock可以提高多个线程进行读操作的效率在性能上来说，如果竞争资源不激烈，两者的性能是差不多的，而当竞争资源非常激烈时（即有大量线程同时竟争），此时 Lock的性能要远远优于synchronized。所以说，在具体使用时要根据适当情况选择
-
Java基础知识之内部类 Java四种内部类。实例内部类：没有static修饰的内部类。静态内部类：使用static修饰的内部类。局部内部类：在方法中定义的内部类。匿名内部类：没有名称的局部内部类。package com.company.innerclasspackage; public class Outer { private String classDesc = "实例内部类访问"; private static String staticClassDesc = "静态内部类访问"; /** * 实例内部类 */ public class Inner1 { public void desc() { System.out.println(classDesc); } } /** * 静态内部类 */ public static class Inner2 { public void Desc() { System.out.println(staticClassDesc); } } public void desc() { String localClassDesc = "局部内部类"; class Inner3{ public void desc(){ System.out.println(localClassDesc); } } } }
-
Effective Java (高效 Java) 第三版-单例模式 Java中单例(`Singleton`)模式是一种广泛使用的设计模式。单例模式的主要作用是保证在Java程序中，某个类只有一个实例存在。一些管理器和控制器常被设计成单例模式。 单例模式有很多好处，它能够避免实例对象的重复创建，不仅可以减少每次创建对象的时间开销，还可以节约内存空间；能够避免由于操作多个实例导致的逻辑错误。如果一个对象有可能贯穿整个应用程序，而且起到了全局统一管理控制的作用，那么单例模式也许是一个值得考虑的选择。饿汉模式public class Singleton{ private static Singleton instance = new Singleton(); private Singleton(){} public static Singleton newInstance(){ return instance; } }类的构造函数定义为`private`的，保证其他类不能实例化此类，然后提供了一个静态实例并返回给调用者。饿汉模式是最简单的一种实现方式，饿汉模式在类加载的时候就对实例进行创建，实例在整个程序周期都存在。它的好处是只在类加载的时候创建一次实例，不会存在多个线程创建多个实例的情况，避免了多线程同步的问题。它的缺点也很明显，即使这个单例没有用到也会被创建，而且在类加载之后就被创建，内存就被浪费了。 这种实现方式适合单例占用内存比较小，在初始化时就会被用到的情况。但是，如果单例占用的内存比较大，或单例只是在某个特定场景下才会用到，使用饿汉模式就不合适了，这时候就需要用到懒汉模式进行延迟加载。懒汉模式public class Singleton{ private static Singleton instance = null; private Singleton(){} public static Singleton newInstance(){ if(null == instance){ instance = new Singleton(); } return instance; } }懒汉模式中单例是在需要的时候才去创建的，如果单例已经创建，再次调用获取接口将不会重新创建新的对象，而是直接返回之前创建的对象。如果某个单例使用的次数少，并且创建单例消耗的资源较多，那么就需要实现单例的按需创建，这个时候使用懒汉模式就是一个不错的选择。但是这里的懒汉模式并没有考虑线程安全问题，在多个线程可能会并发调用它的`getInstance()`方法，导致创建多个实例，因此需要加锁解决线程同步问题，实现如下。public class Singleton{ private static Singleton instance = null; private Singleton(){} public static synchronized Singleton newInstance(){ if(null == instance){ instance = new Singleton(); } return instance; } }synchronized修饰静态方法，可以锁定这个类的所有对象。双重校验锁加锁的懒汉模式看起来即解决了线程并发问题，又实现了延迟加载，然而它存在着性能问题，依然不够完美。synchronized修饰的同步方法比一般方法要慢很多，如果多次调用getInstance()，累积的性能损耗就比较大了。因此就有了双重校验锁，先看下它的实现代码。public class Singleton { private static Singleton instance = null; private Singleton(){} public static Singleton getInstance() { if (instance == null) { synchronized (Singleton.class) { if (instance == null) {//2 instance = new Singleton(); } } } return instance; } }可以看到上面在同步代码块外多了一层`instance`为空的判断。由于单例对象只需要创建一次，如果后面再次调用`getInstance()`只需要直接返回单例对象。因此，大部分情况下，调用`getInstance()`都不会执行到同步代码块，从而提高了程序性能。 不过还需要考虑一种情况，假如两个线程A、B，A执行了`if (instance == null)`语句，它会认为单例对象没有创建，此时线程切到B也执行了同样的语句，B也认为单例对象没有创建，然后两个线程依次执行同步代码块，并分别创建了一个单例对象。为了解决这个问题，还需要在同步代码块中增加`if (instance == null)`语句，也就是上面看到的代码2。我们看到双重校验锁即实现了延迟加载，又解决了线程并发问题，同时还解决了执行效率问题，是否真的就万无一失了呢？这里要提到Java中的指令重排优化。所谓指令重排优化是指在不改变原语义的情况下，通过调整指令的执行顺序让程序运行的更快。JVM中并没有规定编译器优化相关的内容，也就是说JVM可以自由的进行指令重排序的优化。 这个问题的关键就在于由于指令重排优化的存在，导致初始化Singleton和将对象地址赋给instance字段的顺序是不确定的。在某个线程创建单例对象时，在构造方法被调用之前，就为该对象分配了内存空间并将对象的字段设置为默认值。此时就可以将分配的内存地址赋值给instance字段了，然而该对象可能还没有初始化。若紧接着另外一个线程来调用getInstance，取到的就是状态不正确的对象，程序就会出错。 以上就是双重校验锁会失效的原因，不过还好在JDK1.5及之后版本增加了volatile关键字。volatile的一个语义是禁止指令重排序优化，也就保证了instance变量被赋值的时候对象已经是初始化过的，从而避免了上面说到的问题。代码如下：public class Singleton { private static volatile Singleton instance = null; private Singleton(){} public static Singleton getInstance() { if (instance == null) { synchronized (Singleton.class) { if (instance == null) { instance = new Singleton(); } } } return instance; } }静态内部类除了上面的三种方式，还有另外一种实现单例的方式，通过静态内部类来实现。首先看一下它的实现代码：public class Singleton{ private static class SingletonHolder{ public static Singleton instance = new Singleton(); } private Singleton(){} public static Singleton newInstance(){ return SingletonHolder.instance; } }这种方式同样利用了类加载机制来保证只创建一个instance实例。它与饿汉模式一样，也是利用了类加载机制，因此不存在多线程并发的问题。不一样的是，它是在内部类里面去创建对象实例。这样的话，只要应用中不使用内部类，JVM就不会去加载这个单例类，也就不会创建单例对象，从而实现懒汉式的延迟加载。也就是说这种方式可以同时保证延迟加载和线程安全。枚举public enum Singleton{ instance; public void whateverMethod(){} }上面提到的四种实现单例的方式都有共同的缺点：1）需要额外的工作来实现序列化，否则每次反序列化一个序列化的对象时都会创建一个新的实例。2）可以使用反射强行调用私有构造器（如果要避免这种情况，可以修改构造器，让它在创建第二个实例的时候抛异常）。而枚举类很好的解决了这两个问题，使用枚举除了线程安全和防止反射调用构造器之外，还提供了自动序列化机制，防止反序列化的时候创建新的对象。因此，《Effective Java》作者推荐使用的方法。不过，在实际工作中，很少看见有人这么写。
-
Effective Java (高效 Java) 第三版-构造方法参数过多时使用 builder 模式 静态工厂和构造方法都有一个限制：它们不能很好地扩展到很多可选参数的情景。考虑我们有一个人员的类，如果只有姓名是必填的，年龄可选的，也许我们可以提供两个构造函数，但是试想一下，如果有两个类型一样的参数，是不是就没法重载了。或者可选的参数比较多，就比较麻烦了。这个时候，我们就可以考虑builder模式了。 public class Person { private String name; private int age; public static class Builder { private String name; private int age; public Builder(String name) { this.name = name; } public Builder withName(String name) { this.name = name; return this; } public Builder withAge(int age) { this.age = age; return this; } public Person build() { return new Person(this); } } public Person(Builder builder) { this.name = builder.name; this.age = builder.age; } public void desc() { System.out.println("姓名：" + name + ",年龄：" + age); } }调用Person person = new Person.Builder("张三").withAge(30).build(); person.desc();
-
Effective Java (高效 Java) 第三版-考虑使用静态工厂方法替代构造方法 public static Boolean valueOf(boolean b) { return b ? Boolean.TRUE : Boolean.FALSE; }静态工厂方法的优点构造方法没有名字，但是静态工厂方法是有名字的如果构造方法的参数本身并不描述被返回的对象，则具有精心选择名称的静态工厂更易于使用，并且生成的客户端代码更易于阅读。不需要每次调用时都创建一个新对象可以返回其返回类型的任何子类型的对象这种灵活性的一个应用是 API 可以返回对象而不需要公开它的类。 以这种方式隐藏实现类会使 API 非常紧凑。返回对象的类可以根据输入参数的不同而不同声明的返回类型的任何子类都是允许的。 返回对象的类也可以随每次发布而不同。在编写包含该方法的类时，返回的对象的类不需要存在这种灵活的静态工厂方法构成了服务提供者框架的基础，比如 Java 数据库连接 AP（JDBC）。服务提供者框架是提供者实现服务的系统，并且系统使得实现对客户端可用，从而将客户端从实现中分离出来。静态工厂方法的缺点没有公共或受保护构造方法的类不能被子类化要想将Collections框架中任何遍历的实现类进行子类化，是不可能的。程序员很难找到它们它们不像构造方法那样在 API 文档中明确的标注出来。因此，对于提供了静态方法而不是构造器的类来说，想要查明如何实例化一个类是十分困难的。
-
Java中Synchronized的用法 Synchronized是Java中的关键字，是一种同步锁。他修饰的对象有以下几种。修饰一个代码块被修饰的代码块称为同步语句块，其作用的范围是大括号{}括起来的代码，作用的对象是调用这个代码块的对象。修饰一个方法被修饰的方法称为同步方法，其作用的范围是整个方法，作用的对象是调用这个方法的对象。修饰一个静态方法其作用的范围是整个静态方法，作用的对象是这个类的所有对象。修饰一个类其作用的范围是synchronized后面括号括起来的部分，作用主的对象是这个类的所有对象。修饰一个代码块当修饰一个代码块时，我们一定要记住，作用的对象是调用这个代码块的对象。我们下面通过一段代码看一下。public class SynchronizedThread implements Runnable { /** * 计数 */ private static int count; @Override public void run() { synchronized (this) { for (int i = 0; i < 5; i++) { count++; System.out.println(Thread.currentThread().getName() + ":" + count); } } } }这段代码很简单，就是对对类的一个静态变量进行计数。接下来我们看一下调用这段代码的地方。SynchronizedThread synchronizedThread = new SynchronizedThread(); Thread thread1 = new Thread(synchronizedThread,"Thread1"); Thread thread2 = new Thread(synchronizedThread,"Thread2"); thread1.start(); thread2.start();运行上面的代码，查看控制台的输出信息不论我们怎么运行，Thead1与Thread2都是顺序执行的，这正是我们期望的。接下来，我们对上面的代码稍微做一下改动，改动后如下Thread thread3 = new Thread(new SynchronizedThread(),"Thread3"); Thread thread4 = new Thread(new SynchronizedThread(),"Thread4"); thread3.start(); thread4.start();再次运行，查看控制台输出信息可以看到Thead3与Thread4不再是顺序执行。why?Synchronized修饰一个代码块时，作用的对象是调用这个代码块的对象，我们可以看到Thead3与Thread4中是new了一个新的对象，不再是同一个对象，所以Synchronized不再起作用。修饰一个方法修饰一个方法跟修饰一个代码块类似，只是作用域不同。我们继续修改SynchronizedThread，修改后如下：public class SynchronizedThread implements Runnable { /** * 计数 */ private static int count; @Override public void run() { increment(); } public synchronized void increment(){ for (int i = 0; i < 15; i++) { count++; System.out.println(Thread.currentThread().getName() + ":" + count); } } }再次调用上面的两次代码，会发现结果是一样的。修饰静态方法由于静态方法是属于类而不是属于对象，因此synchronized修饰的静态方法锁定的是这个类的所有对象。我们再次对上面的SynchronizedThread进行修改，将increment()方法改成静态方法public class SynchronizedThread implements Runnable { /** * 计数 */ private static int count; @Override public void run() { increment(); } public synchronized static void increment(){ for (int i = 0; i < 15; i++) { count++; System.out.println(Thread.currentThread().getName() + ":" + count); } } }我们再次通过以下代码进行调用Thread thread3 = new Thread(new SynchronizedThread(),"Thread3"); Thread thread4 = new Thread(new SynchronizedThread(),"Thread4"); thread3.start(); thread4.start();查看控制台，可以看到之前不是顺序执行的方法，现在也是按照线程顺序执行了修饰一个类我们再次对上面的SynchronizedThread进行修改public class SynchronizedThread implements Runnable { /** * 计数 */ private static int count; @Override public void run() { increment(); } public static void increment() { synchronized (SynchronizedThread.class) { for (int i = 0; i < 15; i++) { count++; System.out.println(Thread.currentThread().getName() + ":" + count); } } } }我们再次通过以下代码进行调用Thread thread3 = new Thread(new SynchronizedThread(),"Thread3"); Thread thread4 = new Thread(new SynchronizedThread(),"Thread4"); thread3.start(); thread4.start();查看控制台，现在也是按照线程顺序执行的。
-
SpringBoot事务提交后执行异步代码 一般情况下，我们在使用事务时，都是在方法上添加一个@Transactional注解 @Transactional(rollbackFor = Exception.class) public void test1() { }但是有些时候，除了主要核心业务外，我们可能还需要推送消息，但是推送消息我们又需要使用我们核心业务的数据，比如我在核心业务代码中执行了插入，之后需要异步获取插入的数据，推送消息或者发送给异构系统，这个时候，我们可以使用Spring Boot提供的TransactionSynchronization接口，并实现afterCommit方法package com.example.demo.service; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.support.TransactionSynchronizationAdapter; import org.springframework.transaction.support.TransactionSynchronizationManager; import javax.annotation.Resource; @Service public class Test123Service { @Resource Test2Service test2Service; @Transactional(rollbackFor = Exception.class) public void test1() { boolean synchronizationActive = TransactionSynchronizationManager.isSynchronizationActive(); if (synchronizationActive) { TransactionSynchronizationManager.registerSynchronization( new TransactionSynchronizationAdapter() { @Override public void afterCommit() { test2Service.test2(); } } ); } else { test2Service.test2(); } } } package com.example.demo.service; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @Service public class Test2Service { @Async public void test2(){ System.out.println("test2"); } }注意：方法test1()不能调用同一给类中使用了@Async注解的方法test2()（此时@Async会失效）
