代码之家 › 专栏 › 技术社区 › Yomal

在java中,如何知道线程池的任务何时结束

nonblocking future threadpool multithreading java

Yomal · 技术社区 · 8 年前

我正在制作一个新闻更新应用程序。为此,它需要能够在给定的时间段获得更新。在本文中,我创建了一个计时器,在给定的时间段内运行可调用的插件。这里我使用了一个FixedThreadPool(执行器)。为此,我想知道future什么时候完成了它的工作,这样我就可以调用updateHeadlines方法。但当我使用完。get()它会阻塞gui。有没有一种方法可以在没有阻塞的情况下知道作业何时完成,以便我可以在完成后更新GUI。

for (Callable curplugin : plugin) {
            new Timer(((NewsPlugin) curplugin).getUpdateFrequency(), new ActionListener() {
                @Override
                public void actionPerformed(ActionEvent e) {
                    Future<?> finished = executor.submit(curplugin);

                    java.awt.EventQueue.invokeLater(new Runnable() {
                        public void run() {   
                            try {
                                ArrayList<Headline> news = (ArrayList) finished.get();
                                updateHeadlines();
                            } catch (InterruptedException ex) {
                                Logger.getLogger(MainFrame.class.getName()).log(Level.SEVERE, null, ex);
                            } catch (ExecutionException ex) {
                                Logger.getLogger(MainFrame.class.getName()).log(Level.SEVERE, null, ex);
                            }
                        }
                    });
                }
            }).start();
        }

3 回复 | 直到 8 年前

erickson 8 年前

不需要合并 Timer ExecutorService ,或使用回调。相反,计划a Runnable 调用插件并调度 invokeLater 要显示结果:

for (NewsPlugin plugin : plugins) {
  Runnable task = () -> {
    List<Headline> news;
    try {
      news = plugin.call(); /* There's really no need for plugin to be `Callable` */
    } catch (Exception ex) {
      ex.printStackTrace();
    }
    java.awt.EventQueue.invokeLater(this::updateHeadlines);
  };
  int period = plugin.getUpdateFrequency();
  executor.scheduleAtFixedRate(task, period, period, TimeUnit.MILLISECONDS);
}