问题描述
这是代码:
Caused by: java.lang.NullPointerException
at demo.service.AsyncDataLoadService.loadSourceData01(AsyncDataLoadService.java:35) ~[classes/:?]
at demo.service.AsyncFactoryService.doAsyncBetter(AsyncFactoryService.java:43) ~[classes/:?]
at demo.RunApp.run(RunApp.java:39) ~[classes/:?]
不起作用..如果更改列表具有:
public void doAsync(long rowsPerBucket) throws InterruptedException,sqlException,ExecutionException {
List<Bucket> buckets = sourceData01Service.bucketsByRowsPerBucket(rowsPerBucket);
Future<String> process0 = asyncDataLoadService.loadSourceData01(buckets.get(0));
Future<String> process1 = asyncDataLoadService.loadSourceData01(buckets.get(1));
Future<String> process2 = asyncDataLoadService.loadSourceData01(buckets.get(2));
Future<String> process3 = asyncDataLoadService.loadSourceData01(buckets.get(3));
Future<String> process4 = asyncDataLoadService.loadSourceData01(buckets.get(4));
while(!(process0.isDone()) && !(process2.isDone()) && !(process3.isDone()) && !(process4.isDone())) {
Thread.sleep(2000);
}
LOGGER.info("Process 0 => " + process0.get());
LOGGER.info("Process 1 => " + process1.get());
LOGGER.info("Process 2 => " + process2.get());
LOGGER.info("Process 3 => " + process3.get());
LOGGER.info("Process 4 => " + process4.get());
}
工作正常,但我只想让我感兴趣的日志文件。
有什么建议吗?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)