如何Apache点燃异步方法实际上工作?



我的问题是Apache Ignite有putAsync()方法现在它实际上是如何排队我的数据?它会进入记忆吗?它会进入磁盘上的日志吗?我的数据在未来完成后是如何进入数据库的?

例如Kafka,当你想发送数据时,你调用producer.send(),这是异步的,我相信Kafka正在将你的请求排队到一个后台线程正在通过网络刷新的缓冲区中。如果该缓冲区超过了限制,那么它将抛出一个异常。

所以对于Kafka,我知道有另一个线程在后台刷新数据&根据缓冲区的大小,我可以进行多少异步调用是有限制的。

我正在寻找一个类似的解释点燃!

每个线程可能只有一个后台异步调用。如果第一个异步调用尚未完成,则第二个异步调用实际上是同步的。

异步调用也可以是同步的,当它在服务器节点上被调用时,该服务器节点是给定键/分区的主节点。否则,将网络请求发送到主节点,并将控制返回给您的代码。

最新更新