listener - すべての「FutureTask」が計算を終了した後で、別のメソッドを呼び出すにはどうすればよいですか?

Question

異なる PaaS でアプリケーションを作成してデプロイする次の方法があります。

private void deployModulesInPaaS() {

        ExecutorService executor = Executors.newFixedThreadPool(listModules
                .size());

        ModuleParsed mod;

        for (Iterator<ModuleParsed> iterator = listModules.iterator(); iterator
                .hasNext();) {
            mod = (ModuleParsed) iterator.next();
            try {
                switch (mod.getId_paas()) {
                case 1:                     
                    GAEDeployer gaeDeployer = new GAEDeployer(mod.getId_paas(),
                            mod.getId_component(), "//whatever/path");
                    FutureTask<URI> gaeFuture = new FutureTask<URI>(gaeDeployer);
                    executor.execute(gaeFuture);
                    mod.setDeployedURI(gaeFuture.get());
                    break;
                case 2:
                    AzureDeployer azureDeployer = new AzureDeployer(
                            "subscription", "path_certificate", "password",
                            "storageAccountName", "storageAccountKey");
                    FutureTask<URI> azureFuture = new FutureTask<URI>(
                            azureDeployer);
                    executor.execute(azureFuture);
                    mod.setDeployedURI(azureFuture.get());
                    break;                  
                default:
                    System.out.println("The PaaS identifier of module "
                            + mod.getId_component() + " is unknown.");
                    break;
                }

            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }

    }

FutureTaskすべての計算が終了したら、どうすれば別のメソッドを呼び出すことができますか? Command私はパターンについて読んだことがListenerありますが、これらが正しいものであるかどうか、この場合にそれらを実装する方法がわかりません。

Answer 1

ListenableFutureが本当に必要な場合は、このページで「ファンイン」というキーワードで検索してください。

CountDownLatchとオーバーライドする別の方法はFutureTask.done()、お勧めしません:

private void deployModulesInPaaS() {

    CountDownLatch countDownLatch = new CountDownLatch(listModules.size());

    ExecutorService executor = Executors.newFixedThreadPool(listModules
            .size());

    ModuleParsed mod;

    for (Iterator<ModuleParsed> iterator = listModules.iterator(); iterator
            .hasNext();) {
        mod = (ModuleParsed) iterator.next();
        try {
            switch (mod.getId_paas()) {
            case 1:
                GAEDeployer gaeDeployer = new GAEDeployer(mod.getId_paas(),
                        mod.getId_component(), "//whatever/path");
                FutureTask<URI> gaeFuture = new FutureTask<URI>(gaeDeployer) {
                    @Override
                    protected void done() {

                        super.done();
                        countDownLatch.countDown();
                    }
                };
                executor.execute(gaeFuture);
                mod.setDeployedURI(gaeFuture.get());
                break;
            case 2:
                AzureDeployer azureDeployer = new AzureDeployer(
                        "subscription", "path_certificate", "password",
                        "storageAccountName", "storageAccountKey");
                FutureTask<URI> azureFuture = new FutureTask<URI>(
                        azureDeployer) {
                    @Override
                    protected void done() {

                        super.done();
                        countDownLatch.countDown();
                    }
                };
                executor.execute(azureFuture);
                mod.setDeployedURI(azureFuture.get());
                break;
            default:
                System.out.println("The PaaS identifier of module "
                        + mod.getId_component() + " is unknown.");
                break;
            }

        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
    countDownLatch.await();
    // do finally
}