修复parallelStream()

master
zhangw 2018-07-07 16:57:02 +08:00
parent 8023141360
commit efe3e25ce7
3 changed files with 3 additions and 3 deletions

View File

@ -142,7 +142,7 @@ public class JobController {
Method[] methods = clazz.getDeclaredMethods(); Method[] methods = clazz.getDeclaredMethods();
Set<String> names = new HashSet<>(); Set<String> names = new HashSet<>();
Arrays.asList(methods).parallelStream().forEach(m -> { Arrays.asList(methods).forEach(m -> {
int b = m.getModifiers();// public 1 static 8 final 16 int b = m.getModifiers();// public 1 static 8 final 16
if (b == 1 || b == 9 || b == 17 || b == 25) { if (b == 1 || b == 9 || b == 17 || b == 25) {
Class<?>[] classes = m.getParameterTypes(); Class<?>[] classes = m.getParameterTypes();

View File

@ -92,7 +92,7 @@ public class JobServiceImpl implements JobService {
Method[] methods = clazz.getDeclaredMethods(); Method[] methods = clazz.getDeclaredMethods();
Set<String> names = new HashSet<>(); Set<String> names = new HashSet<>();
Arrays.asList(methods).parallelStream().forEach(m -> { Arrays.asList(methods).forEach(m -> {
Class<?>[] classes = m.getParameterTypes(); Class<?>[] classes = m.getParameterTypes();
if (classes.length == 0) { if (classes.length == 0) {
names.add(m.getName()); names.add(m.getName());

View File

@ -32,7 +32,7 @@ public class ColumnProUtil {
if (resultMap != null) { if (resultMap != null) {
List<ResultMapping> list = resultMap.getResultMappings(); List<ResultMapping> list = resultMap.getResultMappings();
list.parallelStream().forEach(rm -> { list.forEach(rm -> {
String column = rm.getColumn(); String column = rm.getColumn();
String pro = rm.getProperty(); String pro = rm.getProperty();
if (StringUtils.isNoneBlank(column) && StringUtils.isNotBlank(pro)) { if (StringUtils.isNoneBlank(column) && StringUtils.isNotBlank(pro)) {