chenlianxiang_Blog 2019-03-28 10:32 采纳率: 66.7%
浏览 1910
已采纳

springboot 多线程 获取不到 service 空对象 无法执行更新数据库

 @Bean
    public ExecutorService executorService(){
        ExecutorService executorService=Executors.newFixedThreadPool(7);
        return executorService;
    }


          @RequestMapping(value = "threadPool")
    public void threadPool() throws Exception {
        int size=6;

        List<stockBean> stockBeans = stockService.queryStock();
        List<stockBean> retInfoList2 = new ArrayList<stockBean>();
//        ExecutorService executorService=Executors.newFixedThreadPool(10);
        List<List<stockBean>> subTaskList = new ArrayList<List<stockBean>>();

        List<FutureTask<List<stockBean>>> futureList=new ArrayList<>();

        //切分任务
        for (int i =0 ;i<=stockBeans.size();i=i+size) {

            subTaskList.add(stockBeans.subList(i, Math.min(i+size, stockBeans.size())));
        }
        for (List<stockBean> alist : subTaskList) {

            FutureTask<List<stockBean>> task = new FutureTask<List<stockBean>>(new theadPool1(alist));
            executorService.execute(task);
            futureList.add(task);

        }

        for (FutureTask<List<stockBean>> futureTask : futureList) {

            retInfoList2.addAll(futureTask.get());
        }

    }



        @Component
public class theadPool1 implements Callable<List<stockBean>> {

    @Autowired
    private IStockService stockService;



    private List<stockBean> stockBeans=null;
    public theadPool1(List<stockBean> stockBeans){
        this.stockBeans=stockBeans;
    }
    @Override
    public List<stockBean> call() throws Exception {
        System.out.println("当前运行的线程名称:" + Thread.currentThread().getName());
        stockService.uptStock(stockBeans);
        System.out.println("当前运行的线程ID:" + Thread.currentThread().getId());
        return stockBeans;

无法进入  stockService.uptStock(stockBeans); 方法进行更新

求大佬帮助

展开全部

  • 写回答

1条回答 默认 最新

  • 红橡树 2019-03-28 11:07
    关注

    你的theadPool1 是@Component组件形式,也就是说这个实例是由spring容器进行维护的,它里面的对象也都是依赖spring进行实例化,但在你的public void threadPool() throws Exception {}这个方法里,你是通过new theadPool1(alist)的形式去实例化这个对象的,这样其中的private IStockService stockService;对象是空值,正常情况下如果你执行调用就会报空指针异常。解决办法由public void threadPool() throws Exception {}这个方法所在的类去实例化类threadPool,也就是通过@Autowired去实例化

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
编辑
预览

报告相同问题?

悬赏问题

  • ¥15 python 3.8.0版本,安装官方库ibm_db遇到问题,提示找不到ibm_db模块。如何解决?
  • ¥15 TMUXHS4412如何防止静电,
  • ¥30 Metashape软件中如何将建模后的图像中的植被与庄稼点云删除
  • ¥20 机械振动学课后习题求解答
  • ¥15 IEC61850 客户端和服务端的通讯机制
  • ¥15 MAX98357a(关键词-播放音频)
  • ¥15 Linux误删文件,请求帮助
  • ¥15 IBMP550小型机使用串口登录操作系统
  • ¥15 关于#python#的问题:现已知七自由度机器人的DH参数,利用DH参数求解机器人的逆运动学解目前使用的PSO算法
  • ¥15 发那科机器人与设备通讯配置