Showing
1 changed file
with
2 additions
and
1 deletions
@@ -3,6 +3,7 @@ package com.yohoufo.order.service.proxy; | @@ -3,6 +3,7 @@ package com.yohoufo.order.service.proxy; | ||
3 | import com.yohoufo.common.utils.DateUtil; | 3 | import com.yohoufo.common.utils.DateUtil; |
4 | import com.yohoufo.dal.order.BuyerOrderStatusFlowMapper; | 4 | import com.yohoufo.dal.order.BuyerOrderStatusFlowMapper; |
5 | import com.yohoufo.dal.order.model.BuyerOrderStatusFlow; | 5 | import com.yohoufo.dal.order.model.BuyerOrderStatusFlow; |
6 | +import com.yohoufo.order.utils.PubThreadFactory; | ||
6 | import org.slf4j.Logger; | 7 | import org.slf4j.Logger; |
7 | import org.slf4j.LoggerFactory; | 8 | import org.slf4j.LoggerFactory; |
8 | import org.springframework.beans.factory.annotation.Autowired; | 9 | import org.springframework.beans.factory.annotation.Autowired; |
@@ -14,7 +15,7 @@ import java.util.concurrent.*; | @@ -14,7 +15,7 @@ import java.util.concurrent.*; | ||
14 | public class OrderStatusFlowService { | 15 | public class OrderStatusFlowService { |
15 | private final Logger logger = LoggerFactory.getLogger(getClass()); | 16 | private final Logger logger = LoggerFactory.getLogger(getClass()); |
16 | 17 | ||
17 | - private ExecutorService executorService = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1000)); | 18 | + private ExecutorService executorService = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1000),new PubThreadFactory("order-status-flow")); |
18 | 19 | ||
19 | @Autowired | 20 | @Autowired |
20 | private BuyerOrderStatusFlowMapper buyerOrderStatusFlowMapper; | 21 | private BuyerOrderStatusFlowMapper buyerOrderStatusFlowMapper; |
-
Please register or login to post a comment