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

Question

我有一个Executors.newfixedThreadPool()它调用了提交，并且显然提交返回了 future 包装的 StringBuffer目的。我需要将结果追加到响应 StringBuffer 中。我可以在 List<Future<StringBuffer>> 中得到结果并再次迭代以附加响应 StringBuffer 。但我想在单次迭代中执行此操作，如下所示，但它会附加 future 对象。有办法实现吗？

    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);

但订单不保证保留