From 67b64ec25727479a8ae4ab6ec4a2a07cb8d9cf61 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Wed, 10 May 2017 15:39:54 +0800 Subject: [PATCH] update --- .../permission/service/impl/LisServiceImpl.java | 39 +++++++++++----------- 1 file changed, 20 insertions(+), 19 deletions(-) diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java index 06739fa..cf41858 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/LisServiceImpl.java @@ -33,25 +33,27 @@ public class LisServiceImpl extends DataAccessLayerService implements LisService System.out.println("saveLis data size = "+ lisList.size()); if (CollectionUtils.isNotEmpty(lisList)) { - int batchSize = 10; - //线程数 - int threadCount = lisList.size()%batchSize == 0 ? lisList.size()/batchSize : lisList.size()/batchSize+1; - System.out.println("threadCount = "+ threadCount); - CountDownLatch countDownLatch = new CountDownLatch(threadCount); - int end = 0; - for (int i = 0; i < lisList.size(); i += batchSize) { - end = (end + batchSize); - if (end > lisList.size()) { - end = lisList.size(); - } - List models = lisList.subList(i, end); - LisSaveTask lis =new LisSaveTask(countDownLatch,masterLisMapper,models); - Thread t1=new Thread(lis); - t1.start(); - System.out.println("spit end"); - } + CountDownLatch countDownLatch = new CountDownLatch(1); + new Thread(new LisSaveTask(countDownLatch,masterLisMapper,lisList)).start(); countDownLatch.await(); +// int batchSize = 10; +// //线程数 +// int threadCount = lisList.size()%batchSize == 0 ? lisList.size()/batchSize : lisList.size()/batchSize+1; +// System.out.println("threadCount = "+ threadCount); +// CountDownLatch countDownLatch = new CountDownLatch(threadCount); +// int end = 0; +// for (int i = 0; i < lisList.size(); i += batchSize) { +// end = (end + batchSize); +// if (end > lisList.size()) { +// end = lisList.size(); +// } +// List models = lisList.subList(i, end); +// new Thread(new LisSaveTask(countDownLatch,masterLisMapper,models)).start(); +// System.out.println("spit end"); +// } +// countDownLatch.await(); + System.out.println("exce end"); } @@ -149,8 +151,7 @@ public class LisServiceImpl extends DataAccessLayerService implements LisService { masterLisMapper.saveLisData(model); } - else - { + else { System.out.println("======================="+model.getVcCardNo()); } } -- 1.8.3.1