@Test

    public void MyCallableTest() throws Exception {

        //创建线程执行对象

        MyCallable myCallable = new MyCallable();

        FutureTask<String> futureTask = new FutureTask<>(myCallable);

        //执行线程

        Thread thread = new Thread(futureTask);

        thread.start();

        //获取线程方法返回数据

        System.out.println(futureTask.get());

    }

    /**

     * 创建实现类

     */

    class MyCallable implements Callable<String>{

        @Override

        public String call() throws Exception {

            System.out.println("test thread by callable");

            return "result";

        }

    }

public class ThreadPoolStu {

    @Test

    public void TestThreadPool1() throws InterruptedException, ExecutionException {

        ExecutorService executorService = Executors.newFixedThreadPool(2);

        //执行Runnable接口实现类 方式1

        MyRunnable runnable1 = new MyRunnable();

        executorService.execute(runnable1);

        //执行Runnable接口实现类 方式2

        MyRunnable runnable2 = new MyRunnable();

        Future<?> future2 = executorService.submit(runnable2);

        System.out.println(future2.get());//若未执行完会阻塞该线程

        //执行Callable接口实现类

        MyCallable callable3 = new MyCallable();

        Future<String> future3 = executorService.submit(callable3);

        System.out.println(future3.get());//若未执行完会阻塞该线程

        // 关闭线程池

        executorService.shutdown();

    }

}

class MyCallable implements Callable<String>{

    @Override

    public String call() throws Exception {

        System.out.println("test thread by callable");

        return "result";

    }

}

class MyRunnable implements Runnable {

    @Override

    public void run() {

        System.out.println("thread execute");

    }

}