Java------实现Callable接口

实现Callable接口

1. 实现Callable接口，需要返回值类型
2. 重写call（）方法，需要抛出异常
3. 创建目标对象
4. 创建执行服务：ExecutorService ser = Executors.newFixedThreadPool(线程的个数)
5. 提交执行：Future result1 = ser.submit
6. 获取结果：boolean r1 = result1.get()
7. 关闭服务：ser.shutdownNow();

代码样式

package Practise.Demo05;import java.util.concurrent.*;public class MyThread implements Callable {@Overridepublic Object call() throws Exception {//run方法线程体for (int i = 0; i < 20; i++) {System.out.println(Thread.currentThread().getName()+"我在看代码------"+i);}return true;}public static void main(String[] args) throws ExecutionException, InterruptedException {MyThread mt1 = new MyThread();MyThread mt2 = new MyThread();MyThread mt3 = new MyThread();//      创建执行服务ExecutorService ser = Executors.newFixedThreadPool(3);//        提交执行Future r1 = ser.submit(mt1);Future r2 = ser.submit(mt2);Future r3 = ser.submit(mt3);//        获取结果boolean rs1 = r1.get();boolean rs2 = r2.get();boolean rs3 = r3.get();//        关闭服务ser.shutdownNow();}
}

运行结果（部分）

pool-1-thread-2我在看代码------0
pool-1-thread-1我在看代码------0
pool-1-thread-3我在看代码------0
pool-1-thread-1我在看代码------1
pool-1-thread-2我在看代码------1
pool-1-thread-1我在看代码------2
pool-1-thread-3我在看代码------1

callable好处：

1. 可以定义返回值
2. 可以抛出异常

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！