diff --git a/src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java b/src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java index 3808181..b8a418f 100644 --- a/src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java +++ b/src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java @@ -34,7 +34,7 @@ public class CustomerDataJob { // 指定 ring buffer字节大小,必需为2的N次方(能将求模运算转为位运算提高效率 ),否则影响性能 private static final int BUFFER_SIZE = 1024 * 1024; //固定线程数 - private static final int THREAD_NUMBERS = 50; + private static final int THREAD_NUMBERS = 60; @Autowired @@ -75,6 +75,8 @@ public class CustomerDataJob { disruptor.start(); + Long start = System.currentTimeMillis(); + int index = 0; DetailDTOMessageEventProducer producer = new DetailDTOMessageEventProducer(ringBuffer, qwMailListManageService, customerService, poiStoreStaffDOMapper); if (StringUtils.isBlank(cpUserIds)) { @@ -146,6 +148,8 @@ public class CustomerDataJob { disruptor.shutdown(); + Long end = System.currentTimeMillis(); + log.debug("同步明细耗时:"+(end-start)); } public void handleList(List cpUserIds) {