https://blog.csdn.net/weixin_69059394/article/details/155944312?spm=1001.2014.3001.5502
上述博客的进程中断中提到了lambda的变量捕获机制。
public class demo6 { public static boolean isFinished=false; public static void main(String[] args) throws InterruptedException { Thread t=new Thread(()->{ while(!isFinished){ System.out.println("hello thread"); try { Thread.sleep(1000); } catch (InterruptedException e) { throw new RuntimeException(e); } } System.out.println("t线程结束"); }); t.start(); Thread.sleep(5000); isFinished=true; } }什么是lambda变量捕获机制?
在lambda表达式中,如果引用了外部的局部变量,那么该变量必须是事实最终(effectively final)的。
什么是事实final?
// 明确的 final final int x = 10; // 事实 final - 初始化后没有修改 int y = 20; // 如果这里再有 y = 30; 就不是事实 final 了 // Lambda 可以捕获事实 final 的变量 Runnable r = () -> System.out.println(x + y);而我在编写原子类AtomicInteger的使用的时候发现了如下问题:
//编写代码, 基于 AtomicInteger 实现多线程自增同一个变量 public class demo2 { //public static AtomicInteger sum = new AtomicInteger(); public static void main(String[] args) throws InterruptedException { AtomicInteger sum = new AtomicInteger(); Thread t1 = new Thread(() -> { for (int i = 0; i < 5000; i++){ sum.getAndIncrement(); } }); Thread t2 = new Thread(() -> { for (int i = 0; i < 5000; i++){ sum.getAndIncrement(); } }); t1.start(); t2.start(); t1.join(); t2.join(); System.out.println(sum); } }我发现将sum初始化在main方法中作为局部变量的时候,程序仍能够运行成功。
按理说这里的lambda应该触发变量捕获机制,sum值是被修改过的,程序应该报错才对。
这是由于我们创建的sum是引用数据类型!
AtomicInteger sum = new AtomicInteger(); // sum 是一个引用变量,指向 AtomicInteger 对象 Thread t1 = new Thread(() -> { for (int i = 0; i < 5000; i++) { sum.getAndIncrement(); // ✅ 修改对象状态,不是修改引用 } }); // sum 的引用没有改变过,是事实 final 的 // sum = new AtomicInteger(); // ❌ 如果加上这行,lambda 就不能捕获了