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)是實際的處理方法。