我尝试使用未来的内部执行器服务，它不会阻塞主线程。然而，这最终会创建两倍的线程数量，这是不可取的。在下面的代码中，我能够在不阻塞的情况下使用future.get()，但我必须创建两倍数量的线程 for (int i : array) {
executor.execute
浏览 148提问于2021-11-21得票数 1
我正在寻找使线程执行超时的方法，并在下面找到了示例：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
回答已采纳
我有一个接受连接的服务器套接字线程。它使用select和超时1秒来做其他事情。但是，有时，当来自以外的的特定信号到达应用程序时，我希望立即执行这些操作。在单个线程程序中，信号中断睡眠和定时IO阻塞函数，如select。但是，在线程中，除了主信号之外，不要中断睡眠。我可以使用pthread_kill()从主<em
浏览 4提问于2022-05-29得票数 0
回答已采纳
2回答
我正在尝试使用JavaFX创建测验应用程序，因为我正在使用Q2.invoke();public void display(McqQuestionthis.view.getBorderPane().setCenter(root);一旦问题被显示，我需要等待直到我得到答案，如果我没有得到答案，下一个问题应该是invoked.so我在display方法中引入了一个线程来等待超时} catch (InterruptedException e) {
浏览 0提问于2018-10-25得票数 0
3回答
for (Future<Long> future : list) { sum += future.get();catch (ExecutionException e) { }现在，当我调用future.get时，它会阻塞调用吗？那么，如果我在android应用程序的主线程上执行此操作，会导致ANR异常吗？我注
浏览 0提问于2012-10-14得票数 3
1回答
当出现新请求时，处理程序将使用此ExecutorService对象提交并行任务。然后等待未来对象的特定超时时间。在所有并行任务完成后，合并并返回activityA响应。该服务应该以每秒~15k的事务量调用，如果这些数据有助于决策b/w，那么这两种方法？
第一种方法的优点是我们不会有创建和关闭新的ExecutorService对象和线程的开销。但是，如果在超时之前没有未来的结果，会发生什
浏览 5提问于2016-06-07得票数 1
3回答
e.toString()+ Thread.currentThread().getId()); } }我希望在1090毫秒超时后得到如果我在public Boolean call() throws Exception {的try块中，在for循环之前放入一个Thread.sleep(2000);，那么我得到的是InterruptedException附言:这只是一个我虚构的例子来展示我的问题。
浏览 1提问于2018-02-13得票数 0
request().get(); }现在，我希望方法getFailingRequest()在4ms之后超时我得到这些信息，超时是注册的，甚至调用了bevor客户端！但线不会被打断。因为这是一个非常基本的例子:我在这里做错什么了吗？-1.0的特性。编辑:解决方案，感谢安迪McCright和阿兹克尔特。由于调用不能<e
浏览 0提问于2018-09-20得票数 2
回答已采纳
假设我有以下一组代码，这些代码可以在将来完成某些任务： case x => Future { x + x }假设我将默认的ExecutionContext提供给这段代码，我知道后台发生了什么，但我想知道的是，对未来的处理是如何完成的？我的意思是，应该有一些线程或一组线程，有可能等待未来完成？这些线程被阻塞了吗？在某种意义上被堵住了，他们真的在等待未来的结束？现在，在
浏览 1提问于2016-05-11得票数 1
回答已采纳
supplyAsync(new MySupplier())ForkJoin线程是否曾经被阻塞过示例2：cf = executor.execute(new Runnable(){//do work }
浏览 3提问于2017-06-28得票数 1
回答已采纳
根据Javadoc的说法，抛出了TimeoutException和CancellationException以及其他两个。TimeoutException和CancellationException有什么不同？看到和袭击了其他人。//除非开发人员显式调用
浏览 4提问于2016-12-20得票数 0
我有一个使用ThreadPoolExecutor异步执行事物的程序。我在Java8中使用CompletableFutures来安排这些任务，然后让线程池中可用的线程执行它们。CompletableFuture[]{futureOne, futureTwo, futureThree}).get(); }我需要在每个线程上设置一个超时，例如10分钟的超时。我
浏览 1提问于2018-03-20得票数 3
回答已采纳
1回答
停止阻塞调用的线程
、、、
我正在开发一个Windows窗体应用程序，以便在通过USB连接的设备上执行一些操作。对于所有的操作，比如读、写和其他事情，我们都有一个定制库。在连接失败的情况下，这个线程在Read函数调用时阻塞，因为这个函数只有在收到数据时才会中断</em
浏览 4提问于2012-08-23得票数 5
问题是，如果Future.get(long, TimeUnit)超时，然后我调用Future.cancel(boolean)，我就没有机会阻止工作线程尝试解析timeout:30任务(我已经在Linux文件中使用timeout:30和attempts:5进行了测试，以便模拟一个长时间运行的Future.cancel(boolean)查询)。这样做的结果是，如果当前运行的工作线程无法停止，当我提交另一个DNS任务时，则必须创建第二个<e
浏览 4提问于2013-04-22得票数 1
我在一个业余爱好项目中使用java.util.concurrent.Semaphore。它用在我正在编写的一个连接池类中。我可以很轻松地使用它，除了这个方法：这迫使我处理InterruptedException现在，我甚至不确定“中断”线程是什么意思，而且我永远不会在我的代码中这样做(好吧，无论如何都不会显式地)。这是否意味着我可以忽略该异常？我该怎么处理呢？
浏览 0提问于2009-06-21得票数 35
1回答
@GaryRussell的回答是：
只有当通道本身可以阻塞时，通道sendTimeout才会应用，例如，一个当前已满的有界队列的QueueChannel；调用方将阻塞，直到队列中的任何一个空间可用，或者超时发生在这种情况下，块位于通道的下游，因此sendTimeout是不相关的(无论如何，它是一个不能阻塞的DirectChannel，订阅的处理程序直接在调用<e
浏览 4提问于2021-04-20得票数 0
回答已采纳
在我的Java 6应用程序中，我有一个线程向主线程提供数据，同时也从DB预取更多的记录。它使用队列作为FIFO缓冲区，其主循环如下所示：当主线程需要在队列满时关闭馈线时，就会出现此问题。由于没有直接控制通道，所以
浏览 17提问于2012-02-13得票数 7
回答已采纳
3回答
如何在不使用睡眠的模拟流(因为它们会对中断作出反应)的情况下测试应用程序代码的行为，以防止IO性能非常差？
例如，我想测试一个具有文件IO线程池的ConcurrentWrapper实用程序。它将每个操作提交给具有超时的ExecutorService和invokeAll()。我不仅要确认带有ConcurrentWrapper的调用在超时之前退出，还
浏览 1提问于2012-06-04得票数 0
Java中的Future.get()有一个奇怪的问题。它总是带着一个InterruptedException返回，但是奇怪的是，异常的原因是空的，所以我不知道是谁打断了我。更糟糕的是，我在调用get()之前检查了一下，而且未来必须做的工作已经完成。
下面是负责输出的代码。f是未来的，可调用的返回一个HashMap，其中代理并不是真正相关的。对不起，如果有太多的打印
浏览 2提问于2010-11-24得票数 9
回答已采纳
2回答
我有一个应用程序，它依赖于一些阻塞操作的超时信号。我假设使用信号超时的方法不适用于线程。Q:如何在线程中实现超时，就像我过去用信号做的那样？
编辑:我遇到了，展示了一个类似于setTimeout()在python中JavaScript中的解决方案。我只想要tool的输出，比如说5秒，所以在特定的超时之后，for循环需要中
浏览 19提问于2017-03-07得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
