java - ListenableFuture で post タスクを実行できない

Question

ファイルをアップロードするために非同期にしようとすると、ListenableFuture を使用しますが、うまくいきません。syn の場合は正常に動作します。

ListenableFuture はリモートへの投稿の実行をサポートしていませんか? URL.openStream() を使用したサンプルが get で問題なく動作することがわかりました。

  private void asynUploadFileToRemote(final String uptoken, final String key, final File file, final PutExtra extra) {
    final ListenableFuture<String> future = pool.submit(new Callable<String>() {
        @Override
        public String call() throws Exception {
            logger.info("starting to upload file");
            // here is to upload a file to remote.
            PutRet putRet = IoApi.put(uptoken, key, file, extra);
            logger.info("end to upload file"); //this log never excute.
            return putRet.getKey();
        }
    });

    future.addListener(new Runnable() {
        @Override
        public void run() {
            try {
                //recerve nothing here
                String key = future.get();
                logger.info("uploadkey:" + key);
            } catch (InterruptedException e) {
                logger.error("Interrupted", e);
            } catch (ExecutionException e) {
                logger.error("Exception in task", e.getCause());
            }
        }
    }, MoreExecutors.sameThreadExecutor());
}

IoApi.put: ファイルをアップロードするだけです。

public static PutRet put(String uptoken, String key, File file,
                         PutExtra extra) {

    if (!file.exists() || !file.canRead()) {
        return new PutRet(new CallRet(400, new Exception(
                "File does not exist or not readable.")));
    }
    if (key == null) {
        key = UNDEFINED_KEY;
    }

    MultipartEntity requestEntity = new MultipartEntity();
    try {
        requestEntity.addPart("token", new StringBody(uptoken));
        FileBody fileBody = new FileBody(file);
        requestEntity.addPart("file", fileBody);
        requestEntity.addPart("key", new StringBody(key));

        if (extra.checkCrc != NO_CRC32) {
            if (extra.crc32 == 0) {
                return new PutRet(new CallRet(400, new Exception("no crc32 specified!")));
            }
            requestEntity.addPart("crc32", new StringBody(extra.crc32 + ""));
        }
    } catch (Exception e) {
        e.printStackTrace();
        return new PutRet(new CallRet(400, e));
    }

    String url = Config.UP_HOST;
    CallRet ret = new Client().callWithMultiPart(url, requestEntity);
    return new PutRet(ret);
}