gpt4 book ai didi

apache-flink - Flink - 用于一系列 API 调用的异步 IO 运算符

转载 作者:行者123 更新时间:2023-12-05 03:55:39 25 4
gpt4 key购买 nike

我们正在使用异步 IO 运算符来调用外部 API。到目前为止,每个事件我们只有一个 api 调用。但是,我们有一个要求,我们必须为每个事件引入多个 API 调用。在运算符中使用线程并进行系列调用确实提供了解决方案,但这是否会破坏使用异步 IO 的目的?使用线程会导致任何其他问题吗?

最佳答案

您现在实际上正在按预期使用 asyncIOasyncIO 不会在其自身上产生任何线程,但希望用户代码直接或间接地这样做。

有两个主要用例:1) 在受雇库返回结果的地方使用外部回调。例如,使用 mongodb 的响应式(Reactive) API。2) 维护自定义线程池(例如,使用Executors.newFixedThreadPool)并使用它手动实现异步操作。

您正在使用第二种方法。

如果不使用它们中的任何一个,asyncIO 只是一个缓慢的 map

关于apache-flink - Flink - 用于一系列 API 调用的异步 IO 运算符,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60059339/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com