与返回值的Java中的并发编程

Question

我在Java中同时编程有问题。我正在研究我的学士学位论文，我必须制作几种方法，这些方法将使我归还一个字符串价值。在期货中，TriggerMessageFututre和GetMetervaluesfuture是一个过程运行，需要在1-5秒之间进行返回字符串值完成后返回。

现在的问题是Future.get（）正在阻止我的主线程。我想在我的主线中调用触发器和getMetervalue methode，而不会阻止我的主线程，并在完成后将答案作为返回值。我无法找到解决问题的方法，因为它是没有返回值的解决方案，或者是阻止线程的解决方案。

private String TriggerMessage(String Messagetyp) throws InterruptedException, ExecutionException{
    Future<String> future = new communicator().TriggerMessageFuture(queue,centralSystem,Messagetyp);

    while(!future.isDone()) {
        System.out.println("[TriggerMessage]: Calculating... ");
        Thread.sleep(500);
    }

    String result = future.get(); //blocking
    return result;
}

private String getMeterValue(String key) throws Exception{
    Future<String> future = new communicator().getMeterValueFuture(queue,centralSystem,key);

    while(!future.isDone()) {
        System.out.println("[getMeterValue]: Calculating...");
        Thread.sleep(500);
    }

    String result = future.get(); //blocking
    return result;
}

Answer 1

这取决于您指的是哪个主线程，此外，如果您可以使用完整的future s而不是普通的旧java future s。

1. 使用main（String [] args）线程，

不可能在没有任何形式的阻塞的情况下进行。如果您没有阻止get，则必须在blockingqueue实现上阻止，否则主线程刚刚结束。

2. 使用Swing Event Dispatch线程，

您需要提交一个连续任务，而future.get是从外部开始的。因此，您要么在任务Future中包含此提交，要么切换到pountableFuture

ExecutorService exec = ...

Future<?> future = exec.submit(() -> {
   var value = someCalculation();
   SwingUtilities.invokeLater(() -> {
       useValueOnEDT(value);
   });
});

或

CompletableFuture<ValueType> cf = ...

cf.whenComplete((value, error) -> {
    SwingUtilities.invokeLater(() -> {
        if (error != null) {
            handleErrorOnEdt(error);
        } else {
            useValueOnEDT(value);
        }
    });
});

3. Android Main线程

这个想法与Swing相同，但是您将必须使用处理程序

// given value
new Handler(Looper.getMainLooper()).post(() -> {
    useValueOnMainLooper(value);
});

Answer 2

您可以将Future包装到完整的future之类的类似中

static <T> CompletableFuture<T> from(Future<T> future) {
    var delegate = new CompletableFuture<T>();

    CompletableFuture.runAsync(() -> {
        try {
            delegate.complete(future.get());
        } catch (Throwable e) {
            delegate.completeExceptionally(e);
        }
    });

    return delegate;
}

，然后使用该alterableFuture，以异步通过其各种来处理完成。 。和当...方法时。