@Override
public void autoInfo(int shardingTotalCount, int shardingItem) {
// 阻塞队列容量声明为100个
ThreadPoolExecutor executorServices = new ThreadPoolExecutor(10, 12,
60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(200));

    // 设置拒绝策略
    executorServices.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

    Map<String, Object> queryMap = new HashMap<String, Object>();
    queryMap.put("shardingItem", shardingItem);
    queryMap.put("shardingTotalCount", shardingTotalCount);

    List<PreferProductPricePo> pricePos = preferProductPriceMapper.selectInfobyCustNumber(queryMap);
    try {

        for (int i = 0; i < pricePos.size(); i++) {
                final String number = pricePos.get(i).getCustNumber();
                executorServices.execute(() -> {
                    //System.out.println(Thread.currentThread().getName() + "-结果:" + number);
                    PreferProductPricePo preferProductPricePo = new PreferProductPricePo();
                    preferProductPricePo.setCustNumber(number);
                    List<PrefetProductPriceSenderInfoPo> prefetProductPriceSenderInfos = preferProductPriceMapper.selectInfobyCustNumberList(preferProductPricePo);
                    for (PrefetProductPriceSenderInfoPo productPriceSenderInfoPo : prefetProductPriceSenderInfos) {
                        System.out.println(number);
                        String custNumber = productPriceSenderInfoPo.getCustNumber();
                        String id = productPriceSenderInfoPo.getId().toString();
                        //cmcDiscountProducer.send(custNumber + id, JSONObject.toJSONString(productPriceSenderInfoPo));
                    }
                });
        }
    } catch (Exception e){
        e.printStackTrace();
    }finally {
        executorServices.shutdown();
    }
    System.out.println("线程执行结束");

}