Java线程池submit时会发生什么?

前言

Java线程池中提交任务运行,通常使用execute()方法就足够了。那如果想要实现在主线程中阻塞获取线程池任务运行的结果,该怎么办呢?答案是submit()方法提交任务。这也是面试中经常被问到的一个知识点,execute()和submit()提交任务的区别是什么?

案例延时

 @Testpublic void testSubmit() throws ExecutionException, InterruptedException {ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5,10,30,TimeUnit.SECONDS,new ArrayBlockingQueue<>(50));// 创建一个计算任务Callable<Integer> myTask = new Callable<Integer>() {@Overridepublic Integer call() throws Exception {int result = 0;for (int i = 0; i < 10000; i++) {result += i;}Thread.sleep(1000);return result;}};log.info("start submit task ......");Future<Integer> future = threadPoolExecutor.submit(myTask);Integer sum = future.get();log.info("get submit result: [{}]", sum);}

运行结果
在这里插入图片描述
主线程的确阻塞等待线程返回

Future类API

我们看到用submit提交任务最后返回一个Future对象,Future表示异步计算的结果。

例子:这个函数的意思是试图取消此任务的执行。1.如果任务已经完成,已经取消或由于其他原因无法取消,则此尝试将失败

boolean cancel(boolean mayInterruptIfRunning)
  1. 如果在调用cancel时此任务尚未启动,则此任务不应运行;
  2. 如果任务已经开始,那么mayInterruptIfRunning参数确实是否应该中断执行此任务的线程以试图停止该任务

线程中断:即线程运行过程中被其他线程给打断了

和execute区别

  • execute(): 提交任务没有返回值,直接线程池中运行任务;
  • submit(): 提交任务有返回值Future,调用get()方法可以阻塞该线程,等待任务运行返回的结果

看看submit()源码

public <T> Future<T> submit(Callable<T> task) {if (task == null) throw new NullPointerException();RunnableFuture<T> ftask = newTaskFor(task);execute(ftask);return ftask;
}

最终都是调用execute()方法,只不过submit()方法在调用前做一层封装,将任务包装成RunnableFuture对象


本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!

相关文章

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部