我想让它做的是检查每一次while循环是否完成了异步工作。这可以使用future.wait_for()来完成。 因为我不想阻塞主循环，所以可以使用future.wait_for(0)。我可以通过检查我启动"async“有多长时间来做到这一点，并验证首先出现的是X毫秒还是返回future_status::ready。 我的问题是，这是一种好的做法，还是有更好的方法呢？更多信息:由于主循环必须启动许多不同的异步作业，这意味着我需
浏览 77提问于2020-07-17得票数 2
我有一个期货列表，我不断循环检查Future.isDone()，如果是，那么我使用Future.get()。但是，在某些情况下，线程会一直运行，为了避免这种情况，我想要超时。请帮助我在不使用Future.get()作为阻塞操作的情况下为未来计时。在堆栈溢出上，大多数关于超时的问题都指向带有超时的Future.get()。
浏览 0提问于2019-10-31得票数 0
我正在寻找使线程执行超时的方法，并在下面找到了示例：https://stackoverflow.com/a/16231834/10015830 Future<?> future = service.submit(new MyCallable()); future.get(100, TimeUnit.MILLISECONDS);
} catch:我不希望父线程在future.get被阻塞。换句话说，我不需要得到我的</
浏览 30提问于2019-04-08得票数 0
回答已采纳
我想用Redis构建一个简单的队列系统，而不是依赖于pub/sub。所以我的(Nodejs)消费者会在一个列表上调用BRPOP，没有什么特别的创意。问题是，是完全且完全依赖于无超时BRPOP的阻塞行为--这意味着它将无限期地阻塞连接，直到将事件推入列表--还是在循环内调用BRPOP，但超时很短。
这两种解决方案的优点和缺点是什么？例如，长时间阻塞的连接/进程会成
浏览 5提问于2016-11-03得票数 1
1回答
我正在使用ExecutorService，它阻塞了主程序一段时间，但我不想阻塞主程序。executor.execute(task); Object result = future.get我正在寻找的是一些机制，我们可以有一个超时，线程在后台运行，而不会阻塞主线程？
浏览 0提问于2016-05-11得票数 1
1回答
我有一组Futures，是通过将Callable%s提交给Executor来创建的。我知道我可以调用Future#get(timeout)，但是如果我在一个循环中为我的所有未来顺序调用它，超时就会开始累积。伪代码： future.get(timeout)
在结果就绪之前，get会使用超时进行阻塞。因此，如果第一个在超时之前完成，第二个也在超时之前完成，依此类推，那么整个执行时间最多是number o
浏览 0提问于2013-07-03得票数 8
回答已采纳
我正在使用套接字库来模拟通过网络发送数据包。
..。Socket.settimeout(值)在阻塞套接字操作上设置超时。值参数可以是表示秒的非负浮点数，也可以是无值浮点数。如果给定一个浮动，则如果超时期间值在操作完成之前已过，则后续套接字操作将引发超时异常。设置None的超时值将禁用套接字操作的超时。s.settimeout
浏览 4提问于2017-03-23得票数 1
回答已采纳
我的C++程序中有一个命名管道。子进程在其中写入一个值，父进程读取该值。我通过mkfifo创建了管道，并且所有操作都是阻塞的(fifo在尝试打开以进行写入和v.v之前不能打开以进行读取。不幸的是，有时我的子进程不会因为子进程运行的程序中的错误而停止。修复这个外部程序中的这个错误不是我的任务，但我希望确保父进程不会在被阻塞的open fifo调用上无限时间停止，而是在一段时间后继续(
浏览 1提问于2011-07-29得票数 0
1回答
在计划中的卡夫卡集群停机期间，我们基本上遇到了以下问题： (显然是使用卡夫卡而不是RabbitMQ )。@GaryRussell的回答是：
只有当通道本身可以阻塞时，通道sendTimeout才会应用，例如，一个当前已满的有界队列的QueueChannel；调用方将阻塞，直到队列中的任何一个空间可用，或者超时发生在这种情况下，块位于通道的下游，因此sendTimeout是不相关的(无论如何，它是一个不能阻塞
浏览 4提问于2021-04-20得票数 0
回答已采纳
1回答
我有一个完全由数据驱动的主循环:它有一个阻塞调用来接收数据并将其存储为‘最近的’(从其他地方访问)。每一段数据都有一个相关的生命周期，在此之后，数据超时并且不再被认为是有效的。每次收到数据时，我都会重置超时。有谁能提出解决办法吗？如果有帮助的话，我已经
浏览 6提问于2009-12-14得票数 0
回答已采纳
2回答
我正在使用c套接字来实现一个可靠的UDP协议。我使用以下代码在等待确认的套接字上设置超时。我不确定为什么我得到了errno 11，资源暂时不可用。Error Reporting: %d : %s\n", errno, strerror(errno)); }
我还尝试了评论中提到的select我在一个循环中有以下代码，但是recvfrom从不超时。
浏览 0提问于2012-11-26得票数 16
回答已采纳
我喜欢为我的函数定义一个运行时间(比如3分钟、5分钟或10分钟)，如果我的函数没有响应-返回/返回任何东西，直到给定，我喜欢从该函数中夺取控制权，或者中断该函数并按我喜欢的方式继续。如果java线程中有任何可能性，我也可以使用任何线程来实现这一点。
浏览 0提问于2012-12-11得票数 0
回答已采纳
我的安卓应用程序应该这样做: MainActivity在开始时启动另一个线程，名为UdpListener，它可以接收来自远程服务器的UDP调用。如果它收到一个包含“更新”内容的数据包，UdpListener应该通知MainActivity做一些事情。我试图在J
浏览 6提问于2012-01-15得票数 2
回答已采纳
注意，这不是一个关于std::condition_variable::wait_for()的问题。我知道这会让人神魂颠倒。我的程序的行为表明这个问题的答案是肯定的，但是STL文档对于condition_variable的情况是非常清楚的。至少在，this_thread的正确答案似乎是否定的。
浏览 8提问于2015-05-29得票数 10
回答已采纳
使用intentservice在后台使用“Google Volley”获取7个Rss Feed链接的数据，并使用ResultReceiver获得结果，但我无法配置如何等待截击响应来完成它的任务，使用ResultReceiver
浏览 0提问于2015-08-04得票数 2
回答已采纳
我写了一个程序，自动评分从学生提交的程序作业。反射用于加载类和实例化对象。无意中的无限循环是学生作业中常见的错误。每个学生提交的内容都有一个线程。监视器跟踪线程的运行时间，并使用stop()方法终止超过允许的最大时间的线程。我的程序正在按预期工作，但不推荐java.lang.Thread中的java.lang.Thread方法。我将非常感谢关于更清洁的解决方案的建议。
谢谢。
浏览 2提问于2014-11-26得票数 6
回答已采纳
3回答
没有消息传递的保证
据我所知，HTTP/HTTPS使用TCP。是否也可以使用UDP建立HTTP/HTTPS连接？
浏览 6提问于2016-10-07得票数 3
任务是从InputStream中读取，并等待结果达到可配置的时间。
对available()的非阻塞调用，您必须使用繁忙的睡眠等待来轮询这个调用。InterruptedException、ExecutionException、IOException { MyClass MyClass =新MyClass()；最终InputStream in = System
浏览 0提问于2019-02-11得票数 2
1回答
我正在尝试构建一个简单的测试用例发送给IBM，以尝试解决问题。当然，调用超时，但应用程序不会死。如果我使用Assert.fail()或者当超时异常被捕获时，
浏览 1提问于2014-06-09得票数 0
我有一个阻塞的TCP套接字作为在C++中实现的TCP客户端的一部分。它试图使用套接字描述符上的::read()调用读取数据。我经常看到这样的情况，即读取返回值为0，但errno的值为EAGAIN。在阻塞套接字的情况下，EAGAIN的意思是什么？我理解这可能是因为触发了读
浏览 3提问于2022-03-07得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号