Java之多线程之Callable与Future
程序员文章站
2022-04-03 12:36:42
...
Java之多线程之Callable与Future
从 Java 5 开始出现了 java.util.concurrent 包,该包在多线程环境中应用广泛。
一、 java.util.concurrent.Callable
Callable 接口 与 Runnable 接口类似,不同的是它们的唯一的 run 方法:
1、Callable 有返回值,Runnable 没有。
Callable 的 run() 方法使用了 泛型类,可以返回任意类型的值。
2、Callable 抛出异常 ,Runnable 没有抛出。
同时 java.util.concurrent.Executors 提供了许多方法,可以操控 Callable 在线程池中运行。
二、java.util.concurrent.Future
Executors 执行 Callable 时会返回一个 Future 对象。使用 Future 我们可以得知 Callable 的运行状态,
以及获取 Callable 执行完后的返回值。
Future 的方法介绍:
- get() :阻塞式,用于获取 Callable/Runnable 执行完后的返回值。
带时间参数的get()重载方法用于最多等待的时间后,如仍未返回则线程将继续执行。
- cancel() :撤销正在执行 Callable 的 Task。
- isDone():是否执行完毕。
- isCancelled():任务是否已经被取消。
三、使用实例
100个任务各耗时 1 秒,用 10 个线程并行执行。
结果:
java.util.concurrent包之Execuotor系列文章
00_Java之 java.util.concurrent 包之概述
01_Java之java.util.concurrent包之Executor与ExecutorService
02_Java之 java.util.concurrent 包之ExecutorService之submit () 之 Future
03_Java之多线程之Callable与Future
04_Java之多线程之Lock
-
转载请注明,
原文出处:http://lixh1986.iteye.com/blog/2351367
引用:
http://www.journaldev.com/1090/java-callable-future-example
-
从 Java 5 开始出现了 java.util.concurrent 包,该包在多线程环境中应用广泛。
一、 java.util.concurrent.Callable
Callable 接口 与 Runnable 接口类似,不同的是它们的唯一的 run 方法:
1、Callable 有返回值,Runnable 没有。
Callable 的 run() 方法使用了 泛型类,可以返回任意类型的值。
2、Callable 抛出异常 ,Runnable 没有抛出。
同时 java.util.concurrent.Executors 提供了许多方法,可以操控 Callable 在线程池中运行。
二、java.util.concurrent.Future
Executors 执行 Callable 时会返回一个 Future 对象。使用 Future 我们可以得知 Callable 的运行状态,
以及获取 Callable 执行完后的返回值。
Future 的方法介绍:
- get() :阻塞式,用于获取 Callable/Runnable 执行完后的返回值。
带时间参数的get()重载方法用于最多等待的时间后,如仍未返回则线程将继续执行。
- cancel() :撤销正在执行 Callable 的 Task。
- isDone():是否执行完毕。
- isCancelled():任务是否已经被取消。
三、使用实例
100个任务各耗时 1 秒,用 10 个线程并行执行。
import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import org.junit.Test; public class T03_MyCallable implements Callable<String> { @Override public String call() throws Exception { Thread.sleep(1000); return Thread.currentThread().getName(); } @Test public void testName() throws Exception { ExecutorService executor = Executors.newFixedThreadPool(10); List<Future<String>> callableList = new ArrayList<Future<String>>(); Callable<String> callable = new T03_MyCallable(); for(int i=0; i< 100; i++){ Future<String> future = executor.submit(callable); callableList.add(future); } for(Future<String> future : callableList){ try { System.out.println(new Date()+ "::"+future.get());//blocked. } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } //shut down the executor service now executor.shutdown(); } /** NOTE: main thread should not complete earlier than sub thread, should at least wait for one task execution time in main thread, should use : future.get() method in main thread. or use: executor.awaitTermination(timeout, unit) in main thread. */ }
结果:
Sun Jan 08 22:01:55 CST 2017::pool-1-thread-1 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-2 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-3 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-4 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-5 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-6 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-7 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-8 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-9 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-10 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-1 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-3 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-5 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-7 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-9 ... ... ... Sun Jan 08 22:01:55 CST 2017::pool-1-thread-2 Sun Jan 08 22:01:55 CST 2017::pool-1-thread-4 Sun Jan 08 22:01:56 CST 2017::pool-1-thread-8
java.util.concurrent包之Execuotor系列文章
00_Java之 java.util.concurrent 包之概述
01_Java之java.util.concurrent包之Executor与ExecutorService
02_Java之 java.util.concurrent 包之ExecutorService之submit () 之 Future
03_Java之多线程之Callable与Future
04_Java之多线程之Lock
-
转载请注明,
原文出处:http://lixh1986.iteye.com/blog/2351367
引用:
http://www.journaldev.com/1090/java-callable-future-example
-
上一篇: android获取手机信息
下一篇: 瑟乌姆战役:铁甲圣骑兵捍卫最后的荣耀
推荐阅读
-
【Java并发解析】Future与Callable
-
Java之多线程之Lock与Condition
-
java多线程之:通过 Callable 和 Future 创建线程
-
【Java并发解析】Future与Callable
-
java多线程之Callable和Future
-
Java多线程编程:Callable、Future和FutureTask浅析(多线程编程之四)
-
Java之多线程之Lock与Condition
-
Java之多线程之Callable与Future
-
Java多线程之Callable和Future的详细介绍(代码示例)
-
Java多线程之Callable和Future的详细介绍(代码示例)