ExecutorService不仅能调用Runnable的任务,它还提供了调用Callable任务的方法。Callable任务中的call方法能够返回任务运行的结果,同时还可以抛出受检的异常,call方法声明了一个throws Exception子句。为了描述ExecutorService的应用,我们看一个实例:
例子中分别创建了Runnable和Callable两个任务对象,service对象分别提交这两个任务并打印出Callable任务的返回值。其中的Future接口代表异步计算的结果,它的名字很好地体现了它将在未来某个时刻才有效,通过Future接口的get方法,我们可以返回Callable任务执行的结果。
例子中通过Executors工具类返回了一个ExecutorService接口的实现类。newFixedThreadPool方法创建了一个线程池队列,它定义了最多有多少个同时工作的线程来处理任务,如果有一个任务在所有线程都在运行时提交,那么它就会在队列中等待一条可用的线程。
除了能够提交单个任务,ExecutorService还能提交一个任务集合,看一个实例:
例子中创建了一个执行任务的集合,通过invokeAll方法集中执行,返回一个结果集合,通过一个for循环返回各个任务的执行结果。
参考链接