@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); 方法进行更新
求大佬帮助
2 回答
慕斯王
TA贡献1864条经验 获得超2个赞
你的theadPool1 是@Component组件形式，也就是说这个实例是由spring容器进行维护的，它里面的对象也都是依赖spring进行实例化，但在你的public void threadPool() throws Exception {}这个方法里，你是通过new theadPool1(alist)的形式去实例化这个对象的，这样其中的private IStockService stockService;对象是空值，正常情况下如果你执行调用就会报空指针异常。解决办法由public void threadPool() throws Exception {}这个方法所在的类去实例化类threadPool，也就是通过@Autowired去实例化
富国沪深
TA贡献1790条经验 获得超9个赞
这边 我后续 采用了两种解决方法， 一种 就是直接从 springboot 的上下文中 去获取实例， 二就是直接将这个service 对象 直接通过传参的方式进行传递，
添加回答
举报
0/150
提交
取消