Java 异步正在阻塞？

Question

在Java上做了很多搜索之后，我真的对以下问题感到很困惑:

1. 为什么我会选择异步方法而不是多线程方法？

2. Java futures应该是非阻塞的。 非阻塞是什么意思？当从 Future 中提取信息的方法(即 get())是阻塞的并且将简单地暂停整个线程直到该方法处理完了吗？也许是在处理完成时敲响教堂钟声的回调方法？

3. 如何使方法异步？什么是方法签名？

   public List<T> databaseQuery(String Query, String[] args){
     String preparedQuery = QueryBaker(Query, args);
     List<int> listOfNumbers = DB_Exec(preparedQuery); // time taking task
     return listOfNumbers;
   }
   

   这个虚构的方法如何变成非阻塞方法？或者，如果您需要，请提供一个简单的同步方法及其异步方法版本。

Answer 1

Why would I choose an asynchronous method over a multi-threaded method?

异步方法允许您减少线程数。您可以发出异步调用，然后在它完成时收到通知，而不是在阻塞调用中占用线程。这释放了线程以同时进行其他处理。

编写异步代码可能会更复杂，但好处是提高了性能和内存利用率。

Java futures are supposed to be non-blocking. What does non-blocking mean? Why call it non-blocking when the method to extract information from a Future--i.e., get()--is blocking and will simply halt the entire thread till the method is done processing ? Perhaps a callback method that rings the church bell of completion when processing is complete?

查看 CompletableFuture ，它是在 Java 8 中添加的。它是一个比 Future 更有用的接口(interface)。其一，它允许您将各种回调和转换链接到 future 。您可以设置在未来完成后运行的代码。正如您猜测的那样，这比在 get() 调用中阻塞要好得多。

例如，给定这样的异步读写方法:

CompletableFuture<ByteBuffer> read();
CompletableFuture<Integer> write(ByteBuffer bytes);

您可以像这样从文件中读取并写入套接字:

file.read()
    .thenCompose(bytes -> socket.write(bytes))
    .thenAccept(count -> log.write("Wrote {} bytes to socket.", count)
    .exceptionally(exception -> {
        log.error("Input/output error.", exception);
        return null;
    });

How do I make a method async? What is the method signature?

你会让它返回一个 future 。

public CompletableFuture<List<T>> databaseQuery(String Query, String[] args);

然后该方法负责在其他线程中执行工作并避免阻塞当前线程。有时您会准备好工作线程。如果没有，您可以使用 ForkJoinPool，这使得后台处理变得非常容易。

public CompletableFuture<List<T>> databaseQuery(String query, String[] args) {
    CompletableFuture<List<T>> future = new CompletableFuture<>();
    Executor executor = ForkJoinPool.commonPool();

    executor.execute(() -> {
        String preparedQuery = QueryBaker(Query, args);
        List<T> list = DB_Exec(preparedQuery); // time taking task
        future.complete(list);
    });
}