From 4dc31d688be8f5984414f69a9bb7e2f7fd4c9440 Mon Sep 17 00:00:00 2001
From: kevin jiang <kevin.jiang@kiisoo.com>
Date: Sun, 17 May 2020 00:58:02 +0800
Subject: [PATCH] =?UTF-8?q?Disruptor=20=E4=BD=BF=E7=94=A8=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/kiisoo/ic/job/CustomerDataJob.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/kiisoo/ic/job/CustomerDataJob.java b/src/main/java/com/kiisoo/ic/job/CustomerDataJob.java
index 8327377..4561338 100644
--- a/src/main/java/com/kiisoo/ic/job/CustomerDataJob.java
+++ b/src/main/java/com/kiisoo/ic/job/CustomerDataJob.java
@@ -30,8 +30,6 @@ public class CustomerDataJob {
     //固定线程数
     private static final int THREAD_NUMBERS = 80;
 
-    //创建线程池
-    ExecutorService executors = Executors.newFixedThreadPool(THREAD_NUMBERS);
 
     @Autowired
     private PrivilageCpUserStoreDOMapper privilageCpUserStoreDOMapper;
@@ -46,8 +44,10 @@ public class CustomerDataJob {
     private CustomerService customerService;
 
 
-
     public void handle(){
+
+        //创建线程池
+        ExecutorService executors = Executors.newFixedThreadPool(THREAD_NUMBERS);
         // 创建缓冲池
         Disruptor<DTOMessage> disruptor = new Disruptor<>(new DTOMessageFactory(), BUFFER_SIZE, executors,
                 ProducerType.SINGLE, new BlockingWaitStrategy());
@@ -58,6 +58,7 @@ public class CustomerDataJob {
         for (int i = 0; i < consumers.length; i++) {
             consumers[i] = new DTOMessageGroup1Consumer();
         }
+
         disruptor.handleEventsWithWorkerPool(consumers);
 
         disruptor.start();