需要帮助在线程运行方法中返回对象

Question

我有一个扩展 Thread 的 Java 类，它基本上如下所示：

public class HttpRequestDispatcher extends Thread {
    private String url;
    private String method; // GET or POST
    private byte[] postData;

    public HttpRequestDispatcher(String url, String method, byte[] postData) {
        this.url = url;
        this.method = method;
        this.postData = postData;
    }

    public HttpRequestDispatcher(String url, String method) {
        this.url = url;
        this.method = method;
    }

    public void run() {
        ...
    }
}

我需要run() 方法来返回ByteArrayOutputStream 或String。但是，因为在Thread的run()方法中，所以无法将方法的返回类型设置为ByteArrayOutputStream或String。

HttpRequestDispatcher 类在名为 OAuth.java 的类中调用。

我该如何解决这种情况？

Answer 1

让它实现Callable<T> 而不是Thread 或Runnable。这里T 必须代表结果的类型。使用ExecutorService 执行它。它将以Future<V> 的形式返回结果。

这是一个 SSCCE 和 String 作为T，只需复制'n'paste'n'运行它。

package com.stackoverflow.q2300433;

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class Test {
    public static void main(String... args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Future<String> future = executor.submit(new Task());
        System.out.println(future.get()); // Prints "result" after 2 secs.

        // Or if you have multiple tasks.
        // List<Future<String>> futures = executor.invokeAll(Arrays.asList(new Task()));
        // for (Future<String> future : futures) {
        //     System.out.println(future.get());
        // }

        executor.shutdown(); // Important!
    }
}

class Task implements Callable<String> {
    public String call() throws Exception {
        Thread.sleep(2000);
        return "result";
    }
}

Answer 2

这个问题有几种解决方案：

• 使用线程外部的数据结构。当你的线程即将完成时，在你的构造函数中传递对象并更新它。

• 使用回调方法。当您的线程完成时，调用回调。

• 使用java.util.concurrent.Future (Java >= 1.5)：

  Future 表示异步计算的结果。提供了检查计算是否完成、等待其完成以及检索计算结果的方法。