Java资深小白，不足之处，或者有任何错误欢迎指出。 --蓝紫
在下面的代码中，List集合使用stream流及中间操作Lambda表达式访问外部变量count 进行累加操作，第20行编译报错：Local variable count defined in an enclosing scope must be final or effectively final。原因是Lambda访问外部变量有一个非常重要的限制，即变量不可变。
@GetMapping("/count")
@ApiOperation(value = "数量")
public Long count() {
// 用户能够访问的系统，通过授权菜单获得
List<PortalSystem> systemList = portalSystemService.userSystem();
AtomicLong atoTotalCount = new AtomicLong();
Long count = 0L;
// 循环系统，得到每个系统的类型
LocalThreadData localData = LocalThreadMap.get();
systemList.parallelStream().forEach(e -> {
LocalThreadMap.put(localData);
try {
String frameType = e.getFramework();
TodoBase todoInstance = getTodo(frameType);
Long totalCount = todoInstance.totalCount(e.getOrgId());
if (totalCount == null) {
totalCount = 0L;
}
//此处报错
count = count + totalCount;
} catch (Exception ex) {
log.error("获取在办数量异常", ex);
} finally {
LocalThreadMap.clear();
}
});
return count;
}
根据提示我们必须使用final修饰count，但此处业务是需要做累加需要修改变量，这里也是不可避免需要使用for增强循环，而for循环中不存在该问题。
解决在foreach做累加的报错
因为是获取多系统的数据，所以使用并行执行的流来提高多线程的任务速度，即：parallelStream，这里就涉及到线程安全问题了。比较两全其美的解决方案是采用AtomicLong（Long的原子类）来替换Long，AtomicLong可以进行原子操作的变量，并且能使得线程安全，修改后的代码如下。
@GetMapping("/count")
@ApiOperation(value = "数量")
public Long count() {
// 用户能够访问的系统，通过授权菜单获得
List<PortalSystem> systemList = portalSystemService.userSystem();
//使用原子类Long
AtomicLong atoTotalCount = new AtomicLong();
// 循环系统，得到每个系统的类型
LocalThreadData localData = LocalThreadMap.get();
systemList.parallelStream().forEach(e -> {
LocalThreadMap.put(localData);
try {
String frameType = e.getFramework();
TodoBase todoInstance = getTodo(frameType);
Long totalCount = todoInstance.totalCount(e.getOrgId());
if (totalCount == null) {
totalCount = 0L;
}
//累加操作
atoTotalCount.addAndGet(totalCount);
} catch (Exception ex) {
log.error("获取在办数量异常", ex);
} finally {
LocalThreadMap.clear();
}
});
//返回值
return atoTotalCount.longValue();
}
第20行中的addAndGet()方法，是AtomicLong的常见方法之一，该方法是先将totalCount的值加上atoTotalCount的值，再获取其总和的值。
特别地，如果使用对象进行foreach循环修改，对其属性进行操作，也不存为这个问题，因为声明一个对象的初始值是内存地址，修改内容不会修改内存地址值，实例如下。
拓展点：
1.AtomicLong的几个常用方法?---------->高并发编程之AtomicLong讲解
2.Long类型对应的concurrent包的类是AtomicLong，想了解concurrent包?---------->Java 并发工具箱之concurrent包
3.什么是parallelStream?---------->深入浅出parallelStream
