如何在 Java 中调用具有多线程的 API？ [复制]

Question

我正在尝试编写一个并行调用 API 的应用程序。虽然，由于某种原因，只要我调用 需要 多次调用的方法，它就不会阻塞父（主）......我已经在网上看到了大量的代码使用 ExecutorService 对象等等，但我的问题是我需要这个线程异步运行，这意味着我不能将调用分组到列表或循环中。

这是我得到的：

  // This is the method I call from the outside.
  public static String callAPI(String _from, String _to, String _text) {
    APIThread t = new APIThread (_from, _to, _text);
    return t.getResult();
  }

然后，在 APIThread 中：

public class APIThread implements Runnable {
    private Thread thread;
    private String data;

    public APIThread(...) {
       this.thread = new Thread(this);
       this.thread.start();
    }

    @Override
    public void run() {
       this.data = doSomeAPIWork();
    }

    public String getResult() {
       return this.data;
    }

    public String doSomeAPIWork() {
       // Use HttpUrlConnection to grab stuff and put it in StringBuilder - return as String
    }
}

这实际上就是我所拥有的 - 只是“伪代码”形式（因为 API 的细节无关紧要）。子线程启动，立即从方法中返回（也就是说APIThread类还没来得及设置数据实例。我感觉这真的很简单，我只是做错了。

编辑：澄清一下，我想要多线程的原因是因为 API 调用是零星的——这意味着我可以一次从程序中的不同位置获取十个左右，并且因为请求大约需要一秒钟或所以，我真的很希望有一个线程池等待执行作业，这意味着，如果我们遇到一个工作，就去做，然后如果我们遇到另一个，同时做那个。换句话说，我希望主线程看到一个 callAPI() 方法，对其进行处理，将其发送到一个线程，然后在其他地方继续（这意味着可能会找到另一个 callAPI() 调用）。

Answer 1

您可以使用接口来满足您的需求。例如，看看这个类：

public class ApiThread {
    private HashMap<String, String> params;
    private String url;
    private OnCompleteListener listener;

    public ApiThread(String url, HashMap<String, String> params) {
       this.url = url;
       this.params = params;
    }

    public void start() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                // Use HttpUrlConnection to grab stuff and put it in result String
                if (ApiThread.this.listener != null) {
                    ApiThread.this.listener.OnComplete(result);
                }
            }
        }).start();
    }

    public ApiThread setListener(OnCompleteListener listener) {
        this.listener = listener;
        return this;
    }
    
    public interface OnCompleteListener {
        void OnComplete(String result);
    }
}

现在看看如何使用它：

HashMap<String, String> params = new HashMap<>();
params.put("username", "John Smith");
params.put("password", "1234567890");
new ApiThread("http://example.com/api/login", params)
    .setListener(new ApiThread.OnCompleteListener() {
        @Override
        public void OnComplete(String result) {
            // do whatever you want with result String, for example:
            System.out.println(result);
        }
    })
    .start();

基本上，它太简单了，但对接口的强大功能很有用。这样，您可以定义您的类在操作完成后应该做什么，而无需等待它完成，并且每当它完成任务（在本例中为 API 调用）时，它将运行传递的接口实现。

通过使用方法链（接口实例设置器），编码风格变得更加美观。