一 项目线程池运用
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());
-
线程池参数
这里面的参数分别为初始线程数
3
,最大线程数6
,线程存活时间0毫秒,使用了LinkedBlockingQueue
,生产消费的阻塞队列,内部是使用ReentrantLock
和Condition
来保证生产和消费的同步,他的长度是1024
,而后面的两个参数就是指定线程池的名称,以方便问题的排查。 -
线程池的执行
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()
方法是没有返回值的,他不去关注方法的返回值信息。 -
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());
通过他我们可以更好的输出方法的运行时长。
网友评论