将 executor.submit 的结果存储到 Stringbuffer.append

Question

我有一个 Executors.newfixedThreadPool() 调用提交，显然提交返回未来包装的 StringBuffer 对象。我需要在响应 StringBuffer 中附加结果。我可以在List<Future<StringBuffer>> 中得到结果，然后再次迭代以追加响应StringBuffer。但我想像下面这样在单次迭代中做到这一点，但它附加了未来的对象。有什么方法可以实现吗？

    ExecutorService es = Executors.newFixedThreadPool(count);
    for (int i = 0; i < count; i++) {
        response.append(es.submit(new Callable<StringBuffer>() {
            @Override
            public StringBuffer call() {
                StringBuffer res = new StringBuffer();
                res = processAddresses(addresses, addressLatch);
                return res;
            }
        }));
    }
    try {
        addressLatch.await();       
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    es.shutdownNow();

Answer 1

你可以这样做：

    final StringBuffer response = new StringBuffer();
    ExecutorService es = Executors.newFixedThreadPool(count);
    for (int i = 0; i < count; i++) {
        es.submit(new Runnable() {
            @Override
            public void run() {
                StringBuffer res = processAddresses(addresses, addressLatch);
                response.append(res);
            }
        });
    }
    es.shutdownNow();
    try {
        es.awaitTermination(1, TimeUnit.HOURS);
    } catch (InterruptedException ex) {
        LOG.log(Level.SEVERE, null, ex);
    }
    System.out.println(response);

但订单不保证保留