public String call() throws Exception {
Log.d( "callable 2 线程是： "+ Thread.currentThread().getName() );
return "执行完了 callable 2" ;
}
};
list.add( callable1 ) ;
list.add( callable2 ) ;
try {
String result = executorService.invokeAny( list ) ;
Log.d( "结果是： "+ result );
} catch (InterruptedException e1) {
e1.printStackTrace();
} catch (ExecutionException e1) {
e1.printStackTrace();
}
//关闭线程池
executorService.shutdown();
}
}
结果：
callable 1 线程是： pool-1-thread-1
callable 2 线程是： pool-1-thread-2
结果是： 执行完了 callable 2
总结：
1、可以看到 Callable 里面的call方法，都是在子线程中运行的，
2、 executorService.invokeAny( list ) ;返回值是任意一个 Callable 的返回值 。具体是哪一个，每个都有可能。
2.5、invokeAll()
方法 invokeAll() 会调用存在于参数集合中的所有 Callable 对象，并且返回一个包含 Future 对象的集合，你可以通过这个返回的集合来管理每个 Callable 的执行结果。需要注意的是，任务有可能因为异常而导致运行结束，所以它可能并不是真的成功运行了。但是我们没有办法通过 Future 对象来了解到这个差异。
package com.app;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class ExecutorTest {
public static void main(String[] args) {
//创建一个线程数固定大小为10的线程池
ExecutorService executorService = Executors.newFixedThreadPool( 10 ) ;
List<Callable<String>> list = new ArrayList<>() ;
//创建第一个 Callable
Callable<String> callable1 = new Callable<String>() {
@Override
public String call() throws Exception {
Log.d( "callable 1 线程是： "+ Thread.currentThread().getName() );
return "执行完了 callable 1" ;
}
};
//创建第二个 Callable
Callable<String> callable2 = new Callable<String>() {
@Override
public String call() throws Exception {
Log.d( "callable 2 线程是： "+ Thread.currentThread().getName() );
return "执行完了 callable 2" ;
}
};
list.add( callable1 ) ;
list.add( callable2 ) ;
List<Future<String>> result;
try {
result = executorService.invokeAll( list );
for (Future<String> future : result) {
Log.d( "结果是： "+ future.get() );
}
} catch (Exception e) {
e.printStackTrace();
}
//关闭线程池
executorService.shutdown();
}
}
结果
callable 1 线程是： pool-1-thread-1
callable 2 线程是： pool-1-thread-2
结果是： 执行完了 callable 1
结果是： 执行完了 callable 2
注意：1：Callable 的call方法都是执行在子线程中的
2： executorService.invokeAll( list ) 是返回值。 但是必须是所有的 Callable对象执行完了，才会返回，返回值是一个list, 顺序和 List<Callable>一样 。在执行的过程中，如果任何一个Callable发生异常，程序会崩溃，没有返回值。
2.6 如何关闭 ExecuteService 服务 ？
当使用 ExecutorService 完毕之后，我们应该关闭它，这样才能保证线程不会继续保持运行状态。 举例来说，如果你的程序通过 main() 方法启动，并且主线程退出了你的程序，如果你还有一个活动的 ExecutorService 存在于你的程序中，那么程序将会继续保持运行状态。存在于 ExecutorService 中的活动线程会阻Java虚拟机关闭。
为了关闭在 ExecutorService 中的线程，你需要调用 shutdown() 方法。ExecutorService 并不会马上关闭，而是不再接收新的任务，一旦所有的线程结束执行当前任务，ExecutorS