方法1:
1.使用线程池工厂类创建线程池对象
* java.util.concurrent.Executors 线程池工厂类
* static ExecutorService newFixedThreadPool(int nThreads)
* 通过此方法可以创建线程池对象
* ExecutorService ex =Executors.newFixedThreadPool(2);
* 2.通过线程池对象 提交线程任务 用于执行
* ExecutorService接口中 方法
* submit(Runnable task)
* 参数需要Runnable实现类对象 (线程任务对象)
* ex.submit(线程任务对象);
方法2:实现Callable接口时
//获取线程池对象
ExecutorService ex = Executors.newFixedThreadPool(2);
//调用submit方法 进行任务提交
Future<String> submit = ex.submit(new SubCallable());
//调用Future的get方法 可以获取到返回的值
String s = submit.get();
System.out.println(s); |
|