future 相关问题

在使用HPX时，有没有办法或解决方案取消等待其他hpx::future get函数？

我的项目中有很多并行任务。我使用 hpx::future（通常在 std::vectorhpx::futrue 中声明）来获取每个任务的结果。每个任务需要不同的时间。当任务...

Python 类型和 futures

我很高兴在Python 3中使用输入模块。另外，我很高兴使用asyncio而不是twisted、tornado和替代品。 我的问题是如何正确定义协程的结果？ 我们应该

std::future 与临时 std::promise

我无法理解 Promise 如何与 future 合作。 我有一个返回 std::future 的函数，如下例所示： std::future calcSomeValue() { } 我的亲...

R：通过parallelly::makeClusterPSOCK运行mirai_cluster

我的目标是使用 docker 容器在由多个 Linux 主机组成的集群上的 R 中执行一些繁重的计算。 在 R 中我想使用 foreach。 要做到这一点，我相信最好的方法是使用

协程可以返回std::future吗？ （无法找到该协程的 Promise 类型）

我尝试编译 CppCon 演示文稿中的协程示例 https://youtu.be/ZTqHjjm86Bw?t=560 不幸的是编译失败： $ g++-10 -pedantic -Wall -std=c++20 -fcoroutines main.cpp...

如何在不调用Future.get的情况下将Future转换为Stream？

假设我有一个 Future 对象列表。List>> futures。我想将其转换为一个 Stream。 显然我可以这样做： 列表列表=新

sql 中的行号、大小写和大于

日期 姓名 预期排名 ID 无效的 顾问 2 100 2024年7月31日 顾问 1 100 2024年3月14日 训练师 1 101 2024年5月2日 训练师 2 101 无效的 安全 1 102 2024年1月3日 安全 2 102 2023年6月12日 安全 ...

Scala Future 奇怪的行为

这段代码有什么问题？为什么我只能看到一个输出？什么返回 futureUserByName 函数？ onComplete 也不起作用。它一定只是简单的 Future，但它不起作用。 导入

%dofuture% foreach 文件未找到警告

尝试让 %dofuture% 工作，但使用以下代码时出现错误。不知道为什么。 库（foreach） 库（并行） 图书馆（doFuture） 计划（多会话，workers=availableCores()） #

如何在返回 JSON 的 API 的多次调用之间添加换行符？

我正在为 Etherscan.io 开发 API 包装器。我有 get_balance() 处理一些问题： 使用超级::配置； 使用 hyper::rt::{Future, Stream}; 使用 hyper::{Body, Client}; 使用 hyper_tls::

Flutter - Geolocator.getCurrentPosition 永远不会返回

我正在 Flutter 上使用 Google 地图 API，而 Geolocator.getCurrentPosition 永远不会返回。 这是我的代码（大部分取自 Simone Alessandria 的 Flutter 项目，还有一些更改来自...

使用 future 向量时“进程已完成，退出代码 -1073740791 (0xC0000409)”

背景 作为 binance-websocket api 和 std::future 使用的新手。我编写了一个程序来测试本地主机和币安服务器之间的时间差，并获取网络延迟。 我推我的...

如何反转 set_value() 并“停用”承诺？

我这里有一个关于同步的问题。我有一个“编写者”线程，它在每次迭代时为承诺分配不同的值“p”。我需要等待shared_futu的“读者”线程...

如何构建我的代码以在返回 Promises 的函数中进行重试

所以我并没有真正对 C++ Promise 和 future 进行过多的研究，我无法理解如何向返回 Promise 的方法添加重试，但我有一个如下所示的方法 承诺 所以我并没有真正对 C++ Promise 和 future 进行过多的研究，我无法理解如何向返回 Promise 的方法添加重试，但我有一个如下所示的方法 promise<void> foo(Request){ /// There are N steps and i want to retry one of them < /// if any one of the step fails the function can return promise<void>::reject(std::errc::bar); .... /// we are at the end, everything succeed return promise::fulfilled(); } 但问题是其中一个步骤不稳定，我想为其添加重试，请注意，我不考虑添加睡眠并重试，因为我不想阻塞线程。 所以我想要的是将所有执行代码移动到一些新的内部方法中，如下所示 promise<void> executeFoo(Request request){ ... /// have all code here ... } 并且比 promise<void> foo(Request request){ /// have a utility class that can invoke methods on some delay /// and a fixed number of time, so something like return promise<void> {Util::Retry(/*delay_between_retries*/, /*number_Of_retries*/, /*some_other_thread*/, [&request](){ executeFoo(request); })}; 令我困惑的是，一旦 Promise foo(Request request) 执行并且第一次返回 Promise，我如何在以后的重试中履行/拒绝 Promise，或者我应该缓存 Promise，但其他请求可能会发生此调用，如出色地。我无法在网上找到任何代码来展示 Promise 如何与重试一起工作，但如果有人有一些资源，请分享。我知道我的代码片段不是实际的代码，因此在这方面的任何见解或指针将不胜感激。 重试函数必须从循环尝试提供的操作的函数创建自己的std::future。 class max_tries_exceeded : std::exception { max_tries_exceeded() : std::exception("maximum tries exceeded") {} }; template <typename Rep, typename Period, typename F, typename... Args> std::future<void> retry(std::chrono::duration<Rep, Period> timeout, size_t tries, F fn, Args... args) { return std::async([=]() mutable { for (; tries; --tries) { auto result = fn(args...); if (result.wait_for(timeout) == std::future_status::ready) { try { return result.get(); } catch() {} } } throw max_tries_exceeded{}; } }

java.util.concurrent.Future.get() 不返回

我有以下Java代码： 最终未来未来 = exeService.submit( 新的可运行（）{ 公共无效运行（）{ myObject.doSomething(); } } ）； future.get(); 哪里

Flutter Future<List<Image>>转换为List<Image>

ListconvertToImgList(Future>listimg){ var li = listimg.asStream(); Future future = listimg.asStream().length; 返回图像； } 你好， 我想要

dask pybind11 如何从 client.submit() 获取正确的值

我有一个关于 python 返回对象值的问题。 使用 pybind11 与 python3 接口 C++ 函数 使用Dask做分布式计算 以下是 progeam 片段。 // -----...

如何等待使用不同`ExecutorServices`创建的`Future`列表

好的，所以我知道这里的第一个答案/评论将是“使用一个 ExecutorService 并使用 invokeAll”。然而，我们保留线程池有一个很好的理由（我不会让人们感到厌烦）

将 Java Future 转变为 CompletableFuture

Java 8 引入了 CompletableFuture，这是可组合的 Future 的新实现（包括一堆 thenXxx 方法）。我想专门使用这个，但是我想使用很多库

使用 DartZ 调用多个 Future 时如何避免嵌套折叠？

我有一段代码，如下所示： 最终 Either resA =等待deleteA(); resA.fold( （失败）=>处理失败（）， （成功）异步{ 最后要么 我有一段代码，如下所示： final Either<Failure, Unit> resA = await deleteA(); resA.fold( (failure) => handleFailure(), (success) async { final Either<Failure, Unit> resB = await deleteB(); resB.fold( (failure) => handleFailure(), (success) => handleSuccess(), ); }, ); 基本上，我想调用第一个函数，它返回失败或单位（成功值并不重要）。 然后，如果第一个函数成功，我想调用另一个函数，它也返回 Future 或 Unit。 我该如何避免在另一个 fold 中进行 fold 的丑陋嵌套调用？ 我正在使用包 dartz，这真的很酷，但缺乏文档。 这个问题好像已经两年没有答案了，最近我对Dart中的函数式编程产生了兴趣，在这里我尝试回答一下。 您可以使用 traverseFuture 继续下一个异步过程，使用 then 链接未来，并使用 bind 绑定结果。最后，折叠结果。这是代码： final Either<Failure, Unit> resA = await deleteA(); resA .traverseFuture((w) => deleteB()) .then((x) => x.bind((y) => y)) .then((z) => z.fold( (l) => handleFailure(l.msg), (r) => handleSuccess(), )); 上面的代码还可以再简化一下。您可以直接调用并链接 deleteA()，而不将其存储到变量中，将 bind 和 fold 链接在一行中，并将 bind((y) => y) 更改为 bind(id) （id 表示来自 dartz 包 f(x) = x 的身份） ）。 这是简化的代码： deleteA() .then((resA) => resA.traverseFuture((w) => deleteB())) .then((x) => x.bind(id).fold( (l) => handleFailure(l.msg), (r) => handleSuccess(), )); 没有 ifs 语句，没有嵌套折叠，只有一个链接函数语句 ✨ 结果呢？错误处理怎么样？结果与之前对双折所做的结果保持不变，上面的代码（单折）使用了面向铁路的编程原理（ROP），如下所示 所以如果deleteA失败，deleteB将不会被执行。 这是错误处理演示和结果输出： 希望能解决您的问题，谢谢😉