异步运行任务并在线程处于活动状态后返回

Question

我一直在使用线程向链接发送GET请求（一切正常）。然而，我需要它异步运行，所以我创建了一个新线程并运行了它。问题是我需要它在线程执行完毕后返回值。我用尝试了while循环！线isActive，但当然，方法体需要一个return语句。我尝试了Countdownlock，您即将看到，但它们暂停了主线程，这是我不想要的。非常感谢您的任何想法。

代码：

    public String getUUID(String username) {
    final String[] returnVar = {"ERROR"};
    final CountDownLatch latch = new CountDownLatch(1);

    Thread thread = new Thread(() -> {

        final String[] response = {"ERROR"};
        final JSONObject[] obj = new JSONObject[1];

        response[0] = ConnectionsManager.sendGet("https://api.mojang.com/users/profiles/minecraft/" + username);

        try {
            obj[0] = (JSONObject) new JSONParser().parse(response[0]);
            returnVar[0] = (String) obj[0].get("id");
        } catch (ParseException e) {
            e.printStackTrace();
        }

        latch.countDown();
    });

    thread.start();


    try {
        latch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    return returnVar[0];
}




Answer 1

这是对线程的不当使用。

您的代码运行方式与以下代码完全相同：

public String getUUID(String username) {
    String response = ConnectionsManager.sendGet("https://api.mojang.com/users/profiles/minecraft/" + username);
    try {
        return (String) ((JSONObject) new JSONParser().parse(response)).get("id");
    } catch (ParseException e) {
        return "ERROR";
    }
}

有几个选项可以进行异步调用。

一个选项是使用CompletableFuture：

CompletableFuture.supplyAsync(getUUID("username")).thenAccept(new Consumer<String>() {
    @Override
    public void accept(String response) {
        // response of async HTTP GET
    }
});

了解更多信息：

• http://www.javaworld.com/article/2078809/java-concurrency/java-concurrency-java-101-the-next-generation-java-concurrency-without-the-pain-part-1.html

Answer 2

我认为您应该考虑使用可调用的，而不是可运行的。有关说明和示例，请参阅此线程。

另外，有点奇怪的是，您将Countdownlock与一个线程一起使用。闩锁有助于确保多个线程尽可能一致地启动，而不是让一些线程在更传统的启动中“领先”。