java中Executor和ExecutorCompletionservice之间的区别
在Java中，Executor和ExecutorCompletionService是两种不同的执行器，它们在处理并发任务时具有不同的功能和用途。
- Executor
Executor是一种执行器接口，它提供了一种执行任务的方式，可以将任务提交给线程池执行。Executor接口定义了一组方法，例如execute()和submit()，这些方法可以用来提交任务。
Executor接口的主要优势在于它可以将任务提交给线程池，从而实现并发执行。这种方式可以提高程序的性能和响应速度，特别是在处理大量任务时。
Executor接口的应用场景包括：
- 处理大量独立任务
- 需要异步执行任务的场景
- 需要控制并发数量的场景
推荐的腾讯云相关产品：腾讯云云协同服务，提供了一种基于云计算的协同服务解决方案，可以实现任务分配、协同编辑、实时通信等功能。
产品介绍链接地址：https://cloud.tencent.com/product/tbaas
- ExecutorCompletionService
ExecutorCompletionService是一种扩展了Executor接口的执行器，它可以用来处理需要等待任务完成并获取结果的场景。
ExecutorCompletionService的主要优势在于它可以提供一种等待任务完成并获取结果的机制，这种机制可以帮助开发者更好地管理并发任务的结果。
ExecutorCompletionService的应用场景包括：
- 需要等待任务完成并获取结果的场景
- 需要对任务结果进行排序或合并的场景
- 需要实现一种基于任务结果的流水线处理机制的场景
推荐的腾讯云相关产品：腾讯云对象存储服务（COS），提供了一种基于云计算的分布式存储服务，可以实现高可用、高扩展、低成本的存储解决方案。
相关·内容
正如问题标题所说，java中的Executor和ExecutorCompletionService类有什么不同？
我对线程是个新手，所以如果有人能用一段代码来解释，那将会有很大帮助。
浏览 0提问于2011-10-14得票数 15
回答已采纳
3回答
用Java控制多线程
、、、、
我有一个“可运行的”线程，它启动了很少的“可调用”线程，并且当上面的线程都完成了它们的工作时，我想显示结果。Connector.java (启动可运行线程) private static void= Executors.newFixedThreadPool(100);
executor
浏览 2提问于2013-08-04得票数 0
ExecutorCompletionService是执行器和ExecutorService类的包装器。通过查看ExecutorCompletionService类源代码，我可以想到许多设计模式。public class ExecutorCompletionService<V> implements CompletionService<V> public ExecutorCompletionService(Executor ex
浏览 2提问于2018-12-17得票数 1
回答已采纳
我正在尝试在具有多个主机并将从多个客户端调用的WebServer中实现WebServer。
从方法
浏览 0提问于2017-03-01得票数 1
回答已采纳
executor = java.util.concurrent.Executors.newSingleThreadExecutor(); new ExecutorCompletionService<String>(executor(ExecutorCompletio
浏览 1提问于2010-04-19得票数 4
我有一个循环中的服务，以便在未来对象可用时接受它们，但我不知道确定所有线程何时完成(从而退出循环)的最佳方法：importjava.util.concurrent.CompletionService;importjava.util.concurrent.Executors;
impo
浏览 4提问于2012-04-03得票数 7
回答已采纳
你能告诉我为什么这个Java程序挂起吗？使用ExecutorCompletionService异步下载HTML是一个简单的程序。我试着使用executor.shutdown()和completionService.shutdown()，但都给了no such method。我认为问题在于executor和completionService，但不知道如何阻止它们不使用关闭方法。import java.io.BufferedReader;
import <
浏览 3提问于2015-02-28得票数 0
回答已采纳
我试图在Java 8中使用固定线程池，只要它保持在相同的功能中，它就工作得很完美。一旦我尝试将executor作为一个参数共享，它就不会并行运行。Executors.newFixedThreadPool(2)；CompletionService<Integer> myCompletionService = }
浏览 0提问于2018-11-20得票数 1
回答已采纳
我有来自ExecutorCompletionService的奇怪行为。该项被添加到ExecutorCompletionService.submit() fine中。我已经创建了打印行，并且可以看到它正在完成可调用的工作线程。一旦发生这种情况，ExecutorCompletionService.take就应该准备好了，但在某些情况下，它会锁定，有时它是正常的？;
import java.util.concurrent.ExecutionExceptio
浏览 1提问于2011-08-08得票数 1
我需要您提供一些关于我正在做一些POC(概念证明)的场景的输入。我刚开始使用java进行多线程处理，并尝试进行一些测试。我的要求是，我希望使用简单的java加载数百万条记录，然后在对数据进行一些转换之后，将数据插入到数据库表中。为此，我想执行一个与完成所有任务相关的简单测试。目前，我希望尝试只在我的executor服务完成之后才完成我的主方法。下面是我尝试过的代码。请任何人帮助我知
浏览 3提问于2016-09-17得票数 3
回答已采纳
对于每一个ID，我需要执行一个可运行的(即。我不关心返回值)，并等待直到它们全部完成。每个可运行的线程从几秒钟到几分钟不等，并行运行大约100个线程是安全的。在当前的解决方案中，我们使用Executors.newFixedThreadPool()，对每个ID调用submit()，然后对每个返回的未来调用get()。代码运行良好，非常简单，因为我不需要处理线程、复杂的等待逻辑等等，它有一个缺点:内存占用。所有仍在排队的Runnable的
浏览 1提问于2019-02-04得票数 3
回答已采纳
我有两门课：TNsyncer.java和DNSClient.java。两者都给出了相同的结果，但是得到结果的方法不同。
两个类都抛出异常
浏览 3提问于2014-03-27得票数 0
我有这样的事情：CompletionService<Boolean> completionService= new ExecutorCompletionService<>(executor);while (i < 40) { i++;executor</e
浏览 3提问于2016-03-18得票数 2
回答已采纳
3回答
有一个通用的任务队列，其中添加了新的任务。我想编写代码，通过将任务添加到队列中来创建更多的任务。将工作添加到队列的任务将通过轮询队列来等待所有任务完成。
使用Java实现它的最佳方式是什么？我在想一些关于简单线程的东西，通过实现一个runnable接口，让它在无限循环中运行，并在其间休眠，醒来看看是否有任何进展。如果进程正在发生，继续循环，如果它已经完成了跳出循环。有没有其他好的和性能高效的方法来实
浏览 1提问于2013-05-01得票数 1
我一直在使用ExecutorCompletionService中的示例代码，并将以下示例代码组合在一起。solve()中的代码按预期工作并打印24solve2()中的代码不会打印任何内容，而且实际上永远不会退出。我已经重写了我的生产代码，以便直接获得() FutureTask的结果，而不是试图从ExecutorCompletionService获得()结果，但它(目前)导致了一些看起来混乱的
浏览 1提问于2009-12-11得票数 1
回答已采纳
1回答
Java并行计算/线程化
、、、
我的问题是:我有200个人。目标是优化人口数量。每个个体都有几个参数，这些参数用于为该个体分配一个值(质量级别)。这个值的计算可以对每个人分别进行，但每一个都需要几秒钟。我的笔记本电脑有4个处理器，我注意到通过使用多个线程(通过可运行线程、1个主线程、7个个人线程、7个个体同时处理，接下来的7个线程)，计算速度可以提高3倍。然而，我对线程一无所知，我的实现也有缺陷。最有可能的是，该程序将终止，但也有可能它将冻结(这可能会花费我1小时的计算)。我运行的其
浏览 4提问于2016-04-28得票数 1
当您提交比当前池大小更多的任务时，我需要知道Java是如何处理的。我的代码如下：CompletionService<MyCallable> serv = new ExecutorCompletionService<MyCallable>(executor);
for (int i
浏览 5提问于2021-05-20得票数 0
回答已采纳
1回答
这是我的代码： int i=0;
ExecutorService pool，array是空的。我想我的代码格式很差，但是我不习惯多线程来发现我的错误。我认为array.add()指令是在线程完成他的工作之前执行的，所以value是空的。我要找的是:每个线程都有自己的工作线程，当worke
浏览 0提问于2019-04-09得票数 0
回答已采纳
2回答
我最好的猜测是，outputInts对每个线程都不是“可见的”，因此不能被写入。Thread t = new Thread(new OneShotTask(j)); }
我已经读到，我应该使用可调用来实现这一点，但我不明白这是如何实现的。另外，像这样的例子似乎表明，我可以使用一个可调用的线程来运行少量线程，在这里，我可能需要在上千个线程的某个地方。
我正在寻求帮助，让上述实现工作，或外行的术语指南，如何才能实现可调用
浏览 1提问于2013-08-15得票数 0
回答已采纳
我正在处理一个项目，其中有大量需要处理的数据元素。每个元素的处理都是独立于其他元素的，我需要从每个元素返回一个结果。我现在要做的是为每个元素创建一个Callable任务来进行处理，并在线程完成时使用ExecutorCompletionService来收集Future结果。然后我有了另一个线程，它从ExecutorCompletionService队列中拉出Future对象。我尝试做的是避免Future对象队列的增长速度快于我将它们从队
浏览 0提问于2013-11-13得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
