-- Start
JDK 1.5 加入了并发包, 其中加入了大量的接口和类, 极大的简化了我们开发并发程序的难度, 下面是一个简单的例子.
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class Test {
public static void main(String[] args) throws Exception {
// 定义一个可以交给某个线程执行的任务
Callable<String> task = new Callable<String>() {
public String call() throws Exception {
return "test";
}
};
// 定义一个线程池
ExecutorService threadPool = Executors.newCachedThreadPool();
// 将我们自定义的任务提交给线程池去执行并返回一个 Future 对象
Future<String> future = threadPool.submit(task);
// 通过 Future 对象, 我们可以得到线程的返回值或取消正在执行的线程
String result = future.get();
System.out.println(result);
// 当所有的线程执行完毕后关闭线程池
threadPool.shutdown();
}
}
1. 定义任务
从上面的例子可以看到, 首先我们必须定义一个可以被线程执行的任务, 我们可以通过实现 Runnable 接口来定义一个任务, 但是 Runnable 接口的 run 方法没有返回值且不能抛出受检查异常, 所以 JDK 1.5 又加入了 Callable 接口, 它的 call 方法既可以有返回值也可以抛出受检查异常.
2. 定义线程池
Executors 类是一个工厂类, 通过它的以下方法我们可以得到一个已经配置好的线程池. 如果你觉得预定义的线程池无法满足你的要求, 你还可以通过ThreadPoolExecutor 或 ScheduledThreadPoolExecutor 来自定义一个线程池, 我们可以对自定义的线程池的各项参数进行配置.
| newCachedThreadPool | 在需要时创建新线程;空闲线程会保留60秒 |
| newFixedThreadPool | 包含固定数量的线程;空闲线程一直保留 |
| newSingleThreadExecutor | 包含一个线程的线程池 |
| newScheduledThreadPool | 可以执行定时任务的线程池 |
| newSingleThreadScheduledExecutor | 可以执行定时任务的单线程池 |
3. 获得线程运行的结果
通过 Future 对象可以得到线程运行的结果, 如果此时线程没有结束, 则它的 get 将会阻塞直到返回结果为止. 除此之外, 我们还可以通过它的 cancel 方法来取消一个线程.
-- 更多参见：Java 精萃
-- 声 明：转载请注明出处
-- Last Updated on 2012-07-04
-- Written by ShangBo on 2012-07-04
-- End