为什么ExecutorService.submit在ExecutionException中包装错误？
ExecutorService.submit在ExecutionException中包装错误的原因是为了提供更详细的错误信息和异常处理能力。
在使用ExecutorService.submit方法提交任务时，任务可能会抛出异常。为了能够捕获并处理这些异常，ExecutorService.submit方法会将任务的异常包装在ExecutionException中返回给调用者。
通过将异常包装在ExecutionException中，可以在调用者端获取到更详细的错误信息，包括异常的类型、堆栈轨迹等。这样可以帮助开发人员更好地定位和解决问题。
此外，将异常包装在ExecutionException中还可以方便地进行异常处理。调用者可以通过捕获ExecutionException来处理任务执行过程中的异常，从而避免异常导致整个程序崩溃或无法正常运行。
推荐的腾讯云相关产品：腾讯云函数（Tencent Cloud Function）
腾讯云函数是一种无服务器计算服务，可以让您无需关心服务器管理和运维，只需编写和上传代码，即可快速构建和部署云端应用。腾讯云函数支持多种编程语言，包括Java、Python、Node.js等，可以方便地进行任务提交和异常处理。
产品介绍链接地址：https://cloud.tencent.com/product/scf
相关·内容
3回答
import java.math.BigInteger;
import java.util.concurrent.*;
public class MultiThreadedFib {
private ExecutorService executorService;
public MultiThreadedFib(final int numberOfThreads) {
executorService = Executors.newFixedThreadPool(numberOfThreads);
}
public BigInteger getFibNumberAtIndex(fin
浏览 0提问于2011-10-06得票数 1
回答已采纳
当我编写这段代码时，我得到了一个编译时错误，它说：‘变量在lambda中必须是最终的或实际上是最终的’。
现在，我可以从行中删除i：
futureLists.add(executorService.submit( () -> "Hello“+i)；
解决了问题。
但我想知道，为何会有这样的要求呢？
根据，它只说：
在lambda表达式中使用但未声明的任何局部变量、形式参数或异常参数必须声明为“最终”或“有效”为“最终”，或者在尝试使用时发生编译时错误。
但它并没有说明为什么会存在这样的要求。但是为什么Java工程师要对lambda执行这样的要求呢？
public clas
浏览 5提问于2018-05-21得票数 9
回答已采纳
下面是我正在编写的一些代码中的一小部分，哪些代码更好/更快/更好？
1.
for (Future<Subscription> future : futures) {
try {
executorService.submit(new Updater(future.get()));
} catch (ExecutionException e) {
logger.error(e, e);
}
}
2.
for (Future<Subscription> future : futures) {
浏览 0提问于2013-05-23得票数 2
回答已采纳
我想对一个函数进行异步调用，然后返回，而不等待结果(在Java中)。我为此编写的代码是：
ExecutorService executorService = Executors.newSingleThreadExecutor();
executorService.submit(new Callable<Void>()
{
public Void call() throws Exception, TimeoutException {
hostNetworkSystem.updatePortGroup("Management Network",
浏览 1提问于2015-12-12得票数 1
1回答
// Task 1 -- the main thread
SimilarityResponse w2vResponse = questionClassifier.compute(questionInfo);
// Task 2
String sku = questionInfo.getSku();
String question = questionInfo.getQuestion();
Callable<ResponseList> dssmTask = () -> this.dssmCompu
浏览 0提问于2018-10-22得票数 1
回答已采纳
当我在for循环中创建多个线程时，如果采用不同的方法，就会有不同的结果。
private List<Future<Integer>> futureList = new ArrayList<>();
void testThread() throws ExecutionException, InterruptedException {
ExecutorService executorService = new ThreadPoolExecutor(4, 4, 0L, TimeUnit.MILLISECONDS, new LinkedBlo
浏览 3提问于2020-10-04得票数 1
回答已采纳
我需要测试InterruptedException和ExecutionException，并为它们编写JUnits。
在这一点上请给我一些建议。我如何中断线程来复制场景。populateDataForm将启动新的线程并将其添加到期货列表中。
下面是我的示例代码：
class MyTest{
public populateData(){
Collection<Future<?>> futures = new LinkedList<Future<?>>();
DataSet ds = Helper.populateDataF
浏览 1提问于2013-06-19得票数 3
回答已采纳
这是我的方法：
private List<OfficerAccountFilter> createResult(List<Account> accountList) {
List<List<Account>> partedList = Lists.partition(accountList, MAX_LIMIT);
List<OfficerAccountFilter> result = new ArrayList<>();
System.out.println("si
浏览 4提问于2016-08-30得票数 3
我在一个简单的Spring项目中学习ExecutorService。我知道ExecutorService使用submit方法提交任务，并且它将对每个任务使用不同的线程。我不明白新线程到底是从哪里开始的。我知道线程是使用start方法启动的。有人能解释一下在哪里调用start方法吗？
例如，这是我的代码：
try {
ExecutorService executorService = Executors.newFixedThreadPool(3);
Future<Accounts> accountFuture =
executorService
浏览 7提问于2022-10-16得票数 -1
我有一个包含JSON文件的目录，需要迭代才能获得文档dName的名称。多个JSON文件可以具有相同的dName。然后，需要从名为output/dName/match的文件夹中创建一个指向该JSON文件的符号链接。线程首先检查dName文件夹是否存在，如果没有，则首先创建它们。我有下面的代码来创建符号链接。
protected static void copyFile(String docName, Path tFilePath) throws IOException {
final String docFolderName = "output" + docName.su
浏览 4提问于2015-11-13得票数 1
回答已采纳
1回答
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import javafx.concurrent.Task;
public class T {
public static void main(String[] args) {
ExecutorService executorSe
浏览 1提问于2016-10-28得票数 3
回答已采纳
1回答
修饰Java的可调用添加行为
、、、、
让我们假设我们有可能长期运行的任务：
public class LongRunningTask {
public ReturnType doSomething() {
...
}
}
我们希望同时运行这些任务中的许多。
所以，我有我的召唤：
public class LongRunningCallable implements Callable<LongRunningTask> {
private final LongRunningTask task;
...
public ReturnType call() {
浏览 2提问于2016-02-12得票数 1
回答已采纳
我试图学习Java并发性教程。当我运行这个程序的时候，它就被卡住了。谁能帮我弄明白原因吗？
public class App
{
public static void main( String[] args ) {
ExecutorService executorService = Executors.newFixedThreadPool(10);
// Submit a task and accept the placeholder object for return value
Future<Integer> futu
浏览 8提问于2022-09-22得票数 0
1回答
我有个这样的场景。
MainClass
event.addListener(Event e){
if (e == EXPECTED_EVENT)
Future<?> result = executorService.submit(myTask);
}
}
doSomething()
doSomethingElse()
doMoreStuff()
如果其中一项任务失败，是否有任何方法中断主流？
我不知道在哪里以及如何准确地同步异常部分：
try {
Object result = ((Future<?>) expectedFu
浏览 1提问于2015-11-29得票数 0
回答已采纳
1回答
我有以下方法：
public Object someMethod(Object param) {
return performLongCalculations();
}
我把一些耗时的计算放在一个单独的方法中：
private Object performLongCalculations() {
...
}
问题是它返回了一些计算结果。这些计算是在EDT中进行的，并导致冻结UI。
我试图用以下方法解决这个问题：
public Object someMethod(final Object param) {
Object resultObject = new Object(
浏览 5提问于2021-02-12得票数 3
回答已采纳
我正在使用ExecutorService，并提交了2个Callables。
你能告诉我使用ExecutorService.awaitTermination和使用Future.get()有什么区别吗？
我不希望线程无限期地运行，而且每个Future的异常都不应该影响其他线程的Future。
ExecutorService executor = Executors.newFixedThreadPool(2);
Future<MyObject1> obj1 = null;
if (true) {
task1 = executor.submit(
浏览 31提问于2017-05-09得票数 0
在使用时，计算值时的任何潜在错误都会通过抛出ExecutionException的来公开。当然，我可以在调用此方法时记录此异常，但这可能会使人产生误解，因为此异常可能发生在与当前完全不同的时间。
简而言之，我想知道ExecutionException发生的时间。有什么优雅的解决办法吗？
浏览 4提问于2022-04-02得票数 -1
1回答
如果我使用的是Futures
List<Future<String>> results = executorService.invokeAll(tasks);
或
Future<String> res = executorService.submit(new SingleWorker());
System.out.println(res.get());
系统等待任务完成。
即使在上面提到的语句之后有了executorService.shutdownNow();，我也真的不明白系统何时会强制终止文档中提到的现有线程，因为在任务完成并返回未来的之前，系统永远不
浏览 2提问于2016-07-19得票数 0
3回答
我读到了Java的期货和javascript中的承诺。下面是我作为示例编写的代码。我的问题是什么时候开始执行分配给未来的任务？
当创建未来时，如下所示：
contentsFuture = startDownloading(new URL("http://www.example.com"));
或者当我们调用get方法时
final String contents = contentsFuture.get();
执行似乎是在get调用期间开始的，因为它是一个阻塞调用，但是为什么它强迫我将startDownloading调用放在that块中呢？
public cla
浏览 0提问于2014-08-01得票数 0
回答已采纳
我正在尝试使用期货来进行并发api调用。代码： private void init() throws ExecutionException, InterruptedException {
Long start = System.currentTimeMillis();
List<ApiResponse> responses = fetchAllUsingFuture(ids, 3);
log.info(responses.toString());
Long finish = System.currentTimeMillis();
log.i
浏览 4提问于2020-08-01得票数 2
回答已采纳
如何在executorService.submit()回调中添加自定义检查。我希望我的线程不要做任何事情，只要标志是真的。如果标志是假的，那么它应该像往常一样工作。
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Exec
浏览 5提问于2019-10-10得票数 0
回答已采纳
1回答
我正在使用Java 7。
我有一个方法，我希望在一个新线程中执行(异步)，并允许进程的其余部分继续。但是，我有以下代码，但它仍然同步执行。
executeBookingAndApprovalConcurrently(autoBookingEnabled, tripDTO, approvalRequestDetails, approvalRequest, quoteResponse, tripRequirementsResponse, evaluatorsList, evaluationTree, memberId, properties, session);
logger.log(Level.
浏览 3提问于2021-10-14得票数 0
由于AsyncTask()方法已被弃用，我正在尝试替换它。以前，AsyncTask()用于从房间数据库将CardViews加载到RecyclerView列表中。我正在尝试使用CompletableFuture()作为替代，但是列表没有加载。"List getAllCards()“的Dao方法在Android Studio中给出了一条错误消息”该方法的返回值从未使用过“，因此听起来该列表似乎从未从数据库中获得过。存储库从ViewModel获取List方法，ViewModel在MainActivity中获取List方法调用。
我还希望避免使用"ExecutorService.sub
浏览 10提问于2021-04-28得票数 1
1回答
我想要创建搜索和从存储库返回对象的服务，因此:我创建了具有以下方法的接口：
public interface ShapeServicesInterface {
List<ShapeEntity> getAll();
String getName();
}
实现该接口的服务很少：
@Service
@RequiredArgsConstructor
public class CircleEntityService implements ShapeServicesInterface {
private final CircleEntityRepository ci
浏览 5提问于2022-09-21得票数 0
下面是这个类的源代码。
我想验证shutdownNow()是如何为未提交的任务工作的。我在下面的代码中遇到的问题是shutdownNow()返回List<FutureTask>而不是List<Runnable>，我已经提交了包含提交的PrimeProducer实例的List<Runnable>。
In Below program I wanted to get the tasks which where not executed and their state so that I can reschedule them later. name() repre
浏览 3提问于2012-09-19得票数 3
回答已采纳
我已经使用ExecutorService实现了一个TimeoutTask。在下面的方法中，我提交了TimeoutTask，如果它在给定的时间超时，我会取消任务并关闭executor。
private boolean waitForProcessToBeCompleted(long timeOut) {
boolean result = false;
ExecutorService executor = Executors.newSingleThreadExecutor();
// Create a FutureTask w
浏览 4提问于2013-04-16得票数 0
在使用RequestFuture类volley时，我遇到了一个问题。实际上，它只是停留在wait(0)；在doGet()函数中，在下面的RequestFuture类中，它永远不会像我认为的那样被onResponse或onErrorResponse唤醒。
private synchronized T doGet(Long timeoutMs)
throws InterruptedException, ExecutionException, TimeoutException {
if (mException != null) {
throw new Exec
浏览 1提问于2013-09-09得票数 5
因此，我尝试从一个线程中启动一个新线程。
即
function(update):
under certain conditions:
add a new thread running same service as current
理想情况下，我希望新线程运行，当前线程继续执行。
相反，会创建一个新线程，但只有当它完成时，我的宿主线程才会再次继续。
理想情况下，我需要它并发执行，添加新线程的效果与从原始类添加线程的效果相同。
我如何使用executor服务来做到这一点？
我现在初始化如下：
ExecutorService executorService = Executors.ne
浏览 14提问于2018-02-22得票数 0
回答已采纳
1回答
我正在创建，比如说，15个可调用的任务，并提交它们：
List<Future<MyResult>> futures = new ArrayList<Future<MyResult>>();
List<MyResult> myResults = new ArrayList<MyResult>();
for(int i = 1; i <= 15; i++){
Callable<MyResult> task = new MyProcessor(//parameters);
Future<
浏览 4提问于2012-07-31得票数 0
回答已采纳
我是Java并发包的新手，我想尝试使用ExecutorService来控制线程的执行时间。
因此，对于一个持续运行的线程MyThread，我希望在2秒后使用ExecutorService和未来类来停止它。
public class MyThread extends Thread {
public static int count = 0;
@Override
public void run() {
while (true) {
System.out.println(count++);
}
}
}
p
浏览 0提问于2016-01-21得票数 0
回答已采纳
我想使用Mockito来模拟下面的代码片段。
Future<Optional<List<User>>> getUser =
executorService.submit(() -> userRepository.findById(user.getUserId()));
我试过使用下面的代码，但它没有工作
@Mock
private ExecutorService executorService;
@Mock
private userRepository userRepository;
when(
浏览 5提问于2020-10-21得票数 2
回答已采纳
1回答
我需要处理一个包含、100万条记录的文件，并将其保存在redis缓存中。我本来应该用redis管道的，但我没有得到任何信息。我的问题是：
所以我决定使用多线程-执行器框架。我不熟悉多线程，这里是我的代码：
@Async
public void createSubscribersAsync(Subscription subscription, MultipartFile file)throws EntityNotFoundException, InterruptedException, ExecutionException, TimeoutException {
Exe
浏览 0提问于2019-09-24得票数 1
回答已采纳
1回答
我有一个web服务，它被20多个发送数据的服务器连续访问。我曾经使用过activeMQ，其中数据被排队了一段时间，然后使用异步任务，该数据被要求。
我的异步任务线程类如下所示。
public class myConsumer {
public void asyncConsumer() throws InterruptedException, ExecutionException{
final MyReceiver receiver = new MyReceiver();
final ExecutorService executorService
浏览 2提问于2015-09-10得票数 0
2回答
处理多个异常
、、、
我正处于一个可怕的境地，下面的代码总结了这一点。
try {
dangerousCode(); // Declares `throws ExecutionException`
}
catch (ExecutionException ex) {
handleIt();
throw ex;
}
catch (RuntimeException ex) {
handleIt();
throw new ExecutionException(ex);
}
finally {
notifyListeners(); // May throw Runtim
浏览 4提问于2013-12-20得票数 2
回答已采纳
将非Error异常包装在java.util.concurrent.ExecutionException中是有意义的，但为什么错误(例如OutOfMemoryError)也包装在ExecutionExceptions中？不把它们包装在ExecutionException中而抛出Errors是不是更有意义
下面是一个示例代码，它演示了如果您使用-Xmx32m运行它的话
import java.util.ArrayList;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorServ
浏览 2提问于2018-02-18得票数 1
回答已采纳
3回答
在本例中，为什么方法引用不启动线程？
package example;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ESMethodReference {
int i1, i2, result = 0;
ESMethodReference(int i1, int i2){
this.i1 =i1;
this.i2 = i2;
}
public Runnable calcula
浏览 1提问于2017-07-05得票数 3
我正在尝试开发一个弹簧引导应用程序。在没有spring框架的情况下，我用核心java编写了所有核心实现。我在这个春季引导应用程序中使用那个罐子。我想管理我的rest控制器的并发性。因此，在主类中相应地配置ThreadPoolTaskExecutor。理想情况下，我只想让两个并发请求进入execute()方法，我对Async进行了注释。我一次测试两个并发请求，但我在日志中看到我的请求同时进入execute()。所有的任务都是内存密集型的。因此，这些问题在堆内存问题上都失败了。我正在试图找出理想的并发数。我想知道我的配置是否正确，还是我遗漏了什么？谢谢。
这是我的主修课：
@SpringBootA
浏览 2提问于2017-09-11得票数 1
我对Java多线程中的任务有点困惑。也就是说，我有15个对象，它实现了可调用，并由ExecutorService提交。每个可调用程序都有自己的进度条，并使用setProgress方法在for循环中进行更新。我想展示15个可调用者中的3个，它们将在第一、第二和第三位置完成他们的工作，获得他们的名字并将其设置在我现场的标签上。当然，每个可调用的用户都有不同的工作时间。
我创建了任务，并在新线程中启动它，并遍历来自我的ExecutorService的未来任务列表。问题是，在未来列表的第一个元素为真(直到第一个线程完成之前)，我的标签是不可见的。我真的不知道为什么，我会非常感谢你的帮助。
public
浏览 0提问于2018-12-28得票数 2
回答已采纳
我从MSSQL server中提取数据，而应用程序的其余部分严重依赖于guava。有没有办法将int从SQL转换为Ints (芭乐)？我试过了
Primitives.wrap(Ints.class).cast(resultSet.getInt(3)))
并得到"java.util.concurrent.ExecutionException: java.lang.ClassCastException: Cannot cast java.lang.Integer to com.google.common.primitives.Ints“错误。
浏览 0提问于2012-05-15得票数 0
回答已采纳
2回答
假设我有很多对象：
public class Main {
public static DB d1 = new DB(1);
public static DB d2 = new DB(2);
public static DB d3 = new DB(3);
public static DB d4 = new DB(4);
我想修改它们。
public static void main(String[] args) {
d1.modifyObject();
d2.modifyObject();
d3.modi
浏览 1提问于2015-03-19得票数 0
回答已采纳
我为一个简单的迷宫项目工作了一段时间，到了需要使用可调用接口作为线程的地步。在实现和运行之后，我注意到虽然可调用类在后台运行，但我似乎无法在后台进行任何其他工作，比如输入。
我做了一个小项目--强调这个问题，看到当可调用类工作10秒时，我不能同时接受任何输入。以下是代码：
主班
public class Main {
static ExecutorService service = null;
static Future<String> task = null;
public static void main(final String[] argv) t
浏览 5提问于2015-12-23得票数 1
回答已采纳
在我的应用程序中，我试图从android设备传感器中获取数据，然后尝试将它们存储在一个文件中。我已经能够从传感器中检索数据并在EditText中成功地输出它们，但是我无法从EditText中连续地获取数据。而循环在这里根本没有用。线程会创建一个字符串"entry“的副本，但是我需要它在外部，所以我试图使用一个可调用的，但不确定我是否做得对。建议做些同样的事情。
这是我想做的。
btn_start.setOnClickListener(new Button.OnClickListener() {
@Override
public void onClick(
浏览 3提问于2017-09-04得票数 2
回答已采纳
我有一个类似这样的代码，我想编写一个单元测试到下面的代码，完全。我可以点击代码的try部分，但无法知道如何测试catch异常部分。
public class CacheUpdateTask implements Runnable {
private WarehouseCache cache;
private static final int EXPONENTIAL_MULTIPLIER = 100;
private static final int MAXIMUM_TIME_LIMIT = 5;
public CacheUpdateTask(
浏览 3提问于2020-04-27得票数 0
2回答
奇怪的异常传播到主线程
、、、、
在下面的情况中，为什么这两个异常都会传播到主线程？
(这是我配置的一个测试，用于在调用stop()时抛出运行时异常)：
List<Future> futures = new ArrayList<>();
futures.add(executorService.submit(runnable1));
futures.add(executorService.submit(runnable2));
Thread.sleep(1000L); // wait for runnables to run for a while
runnable
浏览 2提问于2017-02-27得票数 0
回答已采纳
2回答
我正在执行基本的加密/解密的四核android手机。
目前，每个文件的加密时间为1.45秒。对于200个文件，大约5分钟。
我可以提高4倍的性能，如果我使用所有的4个核心。
for(i=0;i<200;i++)
{
encrypt(file[i]);
}
将是一个简化的伪码，我现在正在使用。
在android编程中，我如何在所有4个处理器核上并行调用加密功能？
浏览 1提问于2015-01-27得票数 4
回答已采纳
:app:incrementalDebugTasks :app:prePackageMarkerForDebug :app:generateDebugInstantRunAppInfo :app:generateDebugInstantRunAppInfo :app:coldswapKickerDebug :app:transformClassesWithInstantRunSlicerForDebug :app:transformClassesWithDexForDebug在进程中运行dex，Gradle守护进程需要一个更大的堆。它目前大约有910 MB。为了更快地构建，将Gradle守护进
浏览 2提问于2016-08-04得票数 4
回答已采纳
我用两种方式创建Runner。但是:新的不起作用。然后，我在Runner1 1的构造处标记调试器点。调试器点也不起作用。谁能告诉我为什么？
在Runner1 1：：new中与Runnable有什么区别吗？
这是我的密码。
public static void main(String[] args) {
Runnable n1 = Runner1::new;
Runnable n2 = new Runner2();
ExecutorService executorService = Executors.newFixedThreadPool(2);
execut
浏览 2提问于2021-07-27得票数 0
回答已采纳
这是一个关于和线程安全的问题。
作为一个简化的例子，请考虑这个类：
@Builder
public class Avengers {
@Singular
private List<String> members;
}
这会生成一个构建器，在这里我可以这样做：
final Avengers team = Avengers.builder()
.member("Iron Man")
.member("Thor")
.member("Captain America")
.build();
Sy
浏览 14提问于2022-06-10得票数 1
回答已采纳
2回答
我有下面的代码。我希望在执行m1和m2时，通过3个线程并行执行m1。
我怎样才能做到这一点。我正在使用Spring和java 8。是否可以使用executor服务来执行m3()？
@Service
class Main {
@Autowired
Private Other other;
ExecutorService executorService = Executors.newFixedThreadPool(3);
void test_method() {
for (int i = 0; i < 201; i++) {
浏览 2提问于2020-09-23得票数 1
回答已采纳
我读了很多关于ExecutorService的文章，但是我找不到做我需要的事情的方法。
我需要一些并发线程。当它们中的任何一个抛出自定义异常时，所有剩余的任务都会被取消。
这就是我所做的一个例子。该任务同时工作，但不会因异常而中断。
public class Main {
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(2);
List<Future> futures = new A
浏览 4提问于2016-10-27得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
