栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

解决ERROR:Local variable count defined in an enclosing scope must be final or effectively final

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

解决ERROR:Local variable count defined in an enclosing scope must be final or effectively final

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 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 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

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/859481.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号