java多线程创建方式
作者:互联网
int corePoolSize = 20; int maximumPoolSize = 40; long keepAliveTime = 20; TimeUnit unit = TimeUnit.SECONDS; BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(5000); ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue); protected void process(Date data) { executor.execute(new Runnable() { @Override public void run() { try { long start = new Date().getTime(); //实际处理的方法
handle(data);
long end = new Date().getTime(); log.info("data key :" + data.getKey() + ",time:" + (end - start) + "ms" + ",workQueue size" + workQueue.remainingCapacity()); if (workQueue.remainingCapacity() < 500) { log.error("work queue nearly full :data key:" + data.getKey() + ",time:" + (end - start) + "ms" + ",workQueue size" + workQueue.remainingCapacity()); } } catch (Exception e) { log.error("process error", e); } } }); }
1. 传入的数据Data,要设置唯一key,在日志中打印key
2.剩余线程数不足时,打印错误日志
3.handle(data)是实际的处理方法。
标签:java,创建,long,key,workQueue,remainingCapacity,new,多线程,data 来源: https://www.cnblogs.com/lixiaoran/p/15847463.html