博客

java多线程（三）实现Callable接口

    步骤：
    实现 Callable接口
    重写call方法，需要抛出异常
    创建目标对象
    创建执行服务
    提交执行
    获取结果
    关闭服务

import java.util.concurrent.*;

public class Thread03  implements Callable<String> {

    //   重写call方法，需要抛出异常
    @Override
    public String call() throws InterruptedException {
        for(int i = 0;i<10;i++){
            Thread.sleep(200);
        }
        System.out.println( "线程名是"+Thread.currentThread().getName());
        return "线程名是"+Thread.currentThread().getName();
    }

    public static void main(String[] args) throws ExecutionException, InterruptedException {

        //创建目标对象
        Thread03 thread03 = new Thread03();

        //创建3个线程服务
        ExecutorService executorService = Executors.newFixedThreadPool(3);

//        提交执行
        Future<String> f1 = executorService.submit(thread03);
        Future<String> f2 = executorService.submit(thread03);
        Future<String> f3 = executorService.submit(thread03);

//        获取返回结果
        String r1 = f1.get();
        String r2 = f2.get();
        String r3 = f3.get();
//        关闭服务
        executorService.shutdown();

    }
}

实现 Callable接口的好处：可以定义返回值和抛出异常