import java.util.concurrent.*;
public class Testss {
public static void main(String[] args) throws ExecutionException, InterruptedException {
//创建一个线程池
ExecutorService executorService = Executors.newFixedThreadPool(5);
//实现callable接口 接收返回值
Future<Object> submit = executorService.submit(new Callable<Object>() {
public Object call() throws Exception {
// int i = 0;
for (int j = 0; j < 100; j++) {
// i += j;
System.out.println("================");
}
return 0;
}
});
//获取返回值
Object o = submit.get();
// System.out.println(o);
//实现runnable 接口
executorService.execute(new Runnable() {
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println("*****************");
}
}
});
//放入线程池
executorService.shutdown();
}
}