Merge pull request #2 from yangkw/master

增加线程池

src/main/java/com/myapp/main/MaintenanceService.java

@@ -36,11 +36,13 @@ public void execute(JobExecutionContext jobExecutionContext) throws JobExecution
         countLock = size;
         CountDownLatch countDownLatch = new CountDownLatch(countLock);
 
+        ExecutorService executor= Executor.newMyexecutor(size);
         for (int j = 0; j < size; j++) {
             A a = new A(j, z,countDownLatch);
-            Thread t1 = new Thread(a);
-            t1.setName(String.valueOf(j));
-            t1.start();
+//            Thread t1 = new Thread(a);
+            executor.execute(a);
+//            t1.setName(String.valueOf(j));
+//            t1.start();
         }
         try {
             countDownLatch.await();

src/main/java/com/myapp/util/Executor.java

@@ -0,0 +1,16 @@
+package com.myapp.util;
+
+import java.util.concurrent.*;
+
+/**
+ * Created by 杨凯文 on 2017/11/17 0017.
+ */
+public class Executor{
+    /**
+     * Cannot instantiate.
+     */
+    public static ExecutorService newMyexecutor(int size) {
+        return new ThreadPoolExecutor(size,size+10,
+                1, TimeUnit.MINUTES,new ArrayBlockingQueue<Runnable>(16));
+    }
+}