java ListeningExecutorService线程池的实现

package duoXianChengs;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.CountDownLatch;

import com.google.common.util.concurrent.ListeningExecutorService;

public class duoxiancheng3 {
static CountDownLatch cdl;// 线程的数目
static List<String> colList = new ArrayList<String>();
public static void main(String[] args) {
ThreadPools kk = new ThreadPools();
ListeningExecutorService pool = kk.getPool();
cdl = new CountDownLatch(5);// 开启线程的数目
for (int i = 0; i < 5; i++) {
submitTest(pool, colList);
}
try {
cdl.await();// 主线程等待子线程执行完成
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
for (String gg : colList) {
System.out.println(gg);
}
System.out.println(colList.size());
colList.clear();
}

/**
* 
*
* @param pool
* @param insertList
*/
static void submitTest(ListeningExecutorService pool,List<String> insertList) {
pool.submit(() -> {
insertList.add("333");
try {
inc();
} catch (Exception e) {
e.printStackTrace();
}
});
}
/* 上面那种写法就如下面注释掉的写法一样 jdk1.8的功能
static void submitTest1(ListeningExecutorService pool,List<String> insertList) {
pool.submit(new Runnable() {

@Override
public void run() {
insertList.add("333");
try {
inc();
} catch (Exception e) {
e.printStackTrace();
}

}
});
}*/

static synchronized void inc() throws InterruptedException {// 注意，如果不加上synchronized，由于并发写入，结果会不准确
Thread.sleep(1);
cdl.countDown();
}
}

package duoXianChengs;

import com.google.common.util.concurrent.ListeningExecutorService;

import com.google.common.util.concurrent.MoreExecutors;

import javax.annotation.PreDestroy;

import java.util.concurrent.Executors;

public class ThreadPools {

    final ListeningExecutorService pool = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));//设置线程池个数

    public ListeningExecutorService getPool() {

        return pool;

    }

    @PreDestroy

    public void close() {

        pool.shutdown();

    }

}