Java多线程有两个重要的接口,Runnable和Callable,分别提供一个run方法和call方法, 二者是有较大差异的。
Runnable使用场景
1、 作为Thread的构造参数开启新的线程,以下是常用的通过匿名内部类的方式创建线程。
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
System.out.println ("I am a runnable task");
}
});
thread.start();
2、 由于Java只提供单继承,故创建线程时一般通过实现Runnable接口 ,来实现run方法的 具体逻辑。然后实例化,作为Thread的构造参数开启线程。
class RunnableTask implements Runnable {
@Override
public void run() {
System.out.println("I am a runnable task");
}
}
main方法:
RunnableTask runnableTask = new RunnableTask();
Thread threadl = new Thread(runnableTask);
threadl.start();
其实1和2的本质是一样的。
3、作为线程任务提交给线程池,通过线程池维护的工作者线程来执行。
ExecutorService executor = Executors.newCachedThreadPool();
RunnableTask runnableTask = new RunnableTask();
executor.execute(runnableTask);
executor.shutdown();
Callable的使用场景
因为Callable的call方法提供返回值,所以当你需要知道任务执行的结果时,Callable是 个不错的选择。Callable的实现很简单。
如下两个Callable任务分别返回false和0到520整数之和。
@Override
public Boolean call() throws Exception {
return false;
}
}
Class IntegerCallableTask implement Callable
@Override
public Integer call() throws Exception{
int sum = 0;
for (int i = 0; i < 520; i++) {
sum += i;
}
return sum;
}
}
Callable任务通过线程池的submit方法提交。且submit方法返回Future对象,通过Future 的get方法可以获得具体的计算结果。而且get是个阻塞的方法,如果任务未执行完,则一直 等待。
ExecutorService executor = Executors.newCachedThreadPool();
IntegerCallableTask integerCallableTask = new IntegerCallableTask();
Future
executor.shutdown();
try {
System.out.println(future.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
关于 Future 和 FutureTask
对于Calleble来说,Future和FutureTask均可以用来获取任务执行结果,不过Future是个 接口,FutureTask是Futirre的具体实现,而且FutureTask还间接实现了 Runnable接口,也 就是说FutureTask可以作为Runnable任务提交给线程池。
以下是个具体的实例演示FutureTask各种的使用方式。
static class Task implements Callable
@Override
public Integer call() throws Exception {
System.out.println("子线程在进行计算");
Thread.sleep(1000);
int sum = 0;
for (int i = 0; i < 10000; i++)
sum += i;
return sum;
}
}
public static void main(String[] args) throws InterruptedException {
ExecutorService executor = Executors.newCachedThreadPool();
//使用 FutureTask
Callable
FutureTask
executor.submit(futureTask);
//使用 Future
// Callable
// Future
executor.shutdown();
System.out.println("主线程在执行任务");
Thread.sleep(2000);
try {
System.out.println("task 运行结果"+ futureTask.get()) ; //future.get()
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
System.out.println("所有任务执行完毕");
}
这个例子中使用Future和FutureTask都是一样的,都能获得相同的计算结果。
相同点:
1、 都是接口
2、 都可以编写多线程程序
3、 都采用Thread.start()启动线程
主要区别:
Runnable接口 run方法无返回值;Callable接口 call方法有返回值,是个泛型,和Future、FutureTask配合可以用来获取异步执行的结果
Runnable接口 run方法只能抛出运行时异常,且无法捕获处理;Callable接口 call方法 允许抛出异常,可以获取异常信息
注:Callalbe接口支持返回执行结果,需要调用FutureTask.get()得到,此方法会阻塞主进 程的继续往下执行,如果不调用不会阻塞。
Was this helpful?
0 / 0