Future在并发中带回结果。

0 0

Future在并发中带回结果。0

Iterator<Entry<String, List<HostIPModifyVo>>> iter = hostIPModifysMap.entrySet().iterator();
        while (iter.hasNext())
        {
            Entry<String, List<HostIPModifyVo>> entry = iter.next();
            List<HostIPModifyVo> singVMHostIPModifys = entry.getValue();
            PrepareHostIPModifyThread prepareHostIPModifyThread = new PrepareHostIPModifyThread(
                    this, singVMHostIPModifys);
            prepareHostIPModifyThread.setDmuConfigService(dmuConfigService);
            Future<?> future = threadManager.submit(prepareHostIPModifyThread);
            futures.add(future);
            
        }

我构建多个线程并行运行，现在的问题是：如果其中一个线程处理出现问题或不是我预期的结果，那么程序的业务逻辑就不在进行下一步的处理。

请问我该如何做？

问题补充：我这里主要不是强调线程的同步问题。
举个应用场景：
我有3台机器需要安装oracle。客户要求分阶段执行。
1.传送安装包
2.检查安装环境
3.安装oracle
4.安装后处理
比如传送安装包过程中，其中有一个机器出现问题，那么任务就不能进入下一步（下面的阶段类似）。
我现在的做法是遍历3台机器，创建三个线程并发向三台机器传送安装包（代码类似问题中贴出的），如果传送过程中，其中一台机器出错，那么所有机器就不能进入下一阶段，任务失败。现在的问题是我怎么知道那个线程失败呢？

Java 线程并发 future

2014年9月11日 19:03

08284008
1
0 0 5

5个答案按时间排序按投票排序

0 0

任务实现 Callable接口比较好，包含返回值，也能抛出异常。
可以用Future去拿结果时检查是否出错。

2014年9月19日 21:22

dwangel
941
0 1 13

添加评论

0 0

这类问题在《Java并发编程实践》中讨论过。

解决方法是将任务提交和结果接收解离，使用一个并发库里Queue来保存执行完成的Future

BlockingQueue<Future<?>> taskQueue = new BlockingQueue<Future<?>>();
Iterator<Entry<String, List<HostIPModifyVo>>> iter = hostIPModifysMap.entrySet().iterator();  
        while (iter.hasNext())  
        {  
            Entry<String, List<HostIPModifyVo>> entry = iter.next();  
            List<HostIPModifyVo> singVMHostIPModifys = entry.getValue();  
            PrepareHostIPModifyThread prepareHostIPModifyThread = new PrepareHostIPModifyThread(  
                    this, singVMHostIPModifys, taskQueue);  
            prepareHostIPModifyThread.setDmuConfigService(dmuConfigService);  
            threadManager.submit(prepareHostIPModifyThread);  
        }  
int finishedCount = 0;
while(true) {
  Future<?> finished = taskQueue.take();
  //  TODO do something with finished task
  finishedCount++;
  if (finishedCount>=hostIPModifysMap.size()) {
    break;
  }
}

2014年9月15日 09:58

dwangel
941
0 1 13

1条评论

0 0

for(Future f :futures){
 try{
 Object returnValue = f.get();
}catch(Exception e){
 //execute exception happened
}
}

2014年9月12日 13:23

kidding87
1566
1 1 19

2条评论

0 0

这个是同步调用。看调用的返回值走不一样的代码就可以了。

2014年9月11日 21:54

samm
68
0 0 3

1条评论

0 0

线程同步问题，用CountDownLatch,工作线程countDown(),主线程await()阻塞,工作线程全部结束再处理下一步

2014年9月11日 21:31

pjwqq
30
0 0 2

4条评论

已解决问题

未解决问题

排行榜

查看全部排名>>