实战！ 多线程线程池分析

一 项目线程池运用

ExecutorService pool = new ThreadPoolExecutor(3, 6,
        0L, TimeUnit.MILLISECONDS,
        new LinkedBlockingQueue(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());

StopWatch stopWatch=new StopWatch();
stopWatch.start();
final String notifyId=event.notifyId;
LOG.info("transaction.onNotifyBegin.notifyId:{}",notifyId);
Callable callable=new Callable() {
    @Override
    public Boolean call() {
        Transaction transaction = tradeService.findByNotifyId(notifyId);
        if(transaction==null){
            LOG.error("找不到对象,notifyId:{}",notifyId);
            return true;
        }
    }
};

Future future = pool.submit(callable);
stopWatch.stop();
LOG.info("notifyId:{}通知执行结果;{},用时:{}ms",notifyId,future.get(),stopWatch.getTotalTimeMillis());

二 线程池代码分析

ExecutorService pool = new ThreadPoolExecutor(3, 6,
        0L, TimeUnit.MILLISECONDS,
        new LinkedBlockingQueue(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());

1. 线程池参数

   这里面的参数分别为初始线程数3，最大线程数6，线程存活时间0毫秒，使用了LinkedBlockingQueue，生产消费的阻塞队列，内部是使用ReentrantLock和Condition来保证生产和消费的同步，他的长度是1024，而后面的两个参数就是指定线程池的名称，以方便问题的排查。

2. 线程池的执行

    StopWatch stopWatch = new StopWatch();
    stopWatch.start();
    final String notifyId=event.notifyId;
    LOG.info("transaction.onNotifyBegin.notifyId:{}",notifyId);
    Callable callable=new Callable() {
        @Override
        public Boolean call() {
            Transaction transaction = tradeService.findByNotifyId(notifyId);
            if(transaction==null){
                LOG.error("找不到对象,notifyId:{}",notifyId);
                return true;
            }
        }
    };
    Future future = pool.submit(callable);
    stopWatch.stop();
   

   这里面使用了pool.submit(callable); 来执行线程，还有另外一个无参的执行方法excute()，那他们之间有什么区别呢，pool.submit传入Callable类最终返回Future，而Future对象就可以获得线程执行完的返回值，然后对返回值进行判断线程池中的线程是否执行成功，而excute()方法是没有返回值的，他不去关注方法的返回值信息。

3. StopWatch类

   他与线城池无关，他其实是一个计时器类

    StopWatch stop = new StopWatch("TASK");
    stop.start("TASK");
    try {
        Thread.sleep(3000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    stop.stop();
    System.out.println(stop.getTotalTimeMillis());
    System.out.println(stop.prettyPrint());
   

   通过他我们可以更好的输出方法的运行时长。