异步编程和反应式编程

Question

这个问题在我脑海里盘旋了一年左右。实际上，异步和非阻塞有什么区别。当我们在代码中调用阻塞部分时，它就会变成阻塞，这是同步的，同时它不会是非阻塞的。

如果我们在主线程之外创建另一个线程来进行异步编程并且我们必须返回一些值所以我们必须join()在java中定义方法并且join()阻塞操作那么它实际上是异步的吗？

我需要知道以下问题的答案

1. 如果阻塞类似于同步，那么异步和非阻塞之间有什么区别。它应该是相似的吗？如果不是那么为什么？

2. 非阻塞的响应式编程是否完全异步编程？

Answer 1

考虑 2 个并行算法，生产者和消费者。如果消费者比生产者工作得更快，我们必须阻止消费者算法，直到生产者提供新数据。通常，我们有两种方法来阻止消费者：

1. 将消费者实现为一个线程，并阻塞该线程
2. 将消费者实现为一个任务，在线程池上运行，并从该任务返回（并告诉生产者在数据准备好时重新启动任务）。

实现消费者的第一种方法是同步的，第二种是异步的。

现在考虑一个相反的情况：生产者比消费者快。再说一次，我们有两种选择来阻止生产者：

1. 将生产者实现为一个线程并阻塞该线程
2. 将生产者实现为一个任务，在线程池上运行，并从该任务返回（并告诉消费者在能够接收数据时重新启动生产者任务）。

当然，第一个选项是同步的，第二个选项是异步的。定义快速生产者和慢速消费者之间交互的第二个异步选项称为reactive programming。

因此，反应式编程是异步编程的一个子集。定义异步活动之间的交互有很多不同的协议，反应式编程只是其中之一，无法涵盖异步通信的所有可能情况。

我试图在模块https://github.com/akaigoro/df4j/tree/API-8/df4j-protocols 中收集异步协议。可以（重新）发明其他协议，例如，带有或不带有背压的字节流，类似于同步InputStream和OutputStream。我相信任何同步协议都有其异步模拟。