线程创建的三种方式

2021-07-24

字数统计: 960字 | 阅读时长≈ 3分

java创建线程的三种方法

1、创建Thread 对象，并且实现run方法最后 thread.start()。
2、实现runnable 接口 Thread runnable 作为Thread 的构造参数。
3、通过Callable和Future接口创建线程。
前面两种都很简单，这里说一下通过Callable 和 Future 接口创建线程的代码:
通过这两个接口创建线程，你要知道这两个接口的作用，下面我们就来了解这两个接口：
通过实现Runnable接口创建多线程时，Thread类的作用就是把run()方法包装成线程的执行体，
那么，是否可以直接把任意方法都包装成线程的执行体呢？从JAVA5开始，JAVA提供提供了Callable接口，
该接口是Runnable接口的增强版，Callable接口提供了一个call()方法可以作为线程执行体，
但call()方法比run()方法功能更强大，call()方法的功能的强大体现在：
1、call()方法可以有返回值；
2、call()方法可以声明抛出异常；

从这里可以看出，完全可以提供一个Callable对象作为Thread的target，
而该线程的线程执行体就是call()方法。但问题是：Callable接口是JAVA新增的接口，
而且它不是Runnable接口的子接口，所以Callable对象不能直接作为Thread的target。
还有一个原因就是：call()方法有返回值，call()方法不是直接调用，而是作为线程执行体被调用的，
所以这里涉及获取call()方法返回值的问题。

于是，JAVA5提供了Future接口来代表Callable接口里call()方法的返回值，
并为Future接口提供了一个FutureTask实现类，该类实现了Future接口，
并实现了Runnable接口，所以FutureTask可以作为Thread类的target，
同时也解决了Callable对象不能作为Thread类的target这一问题。

在Future接口里定义了如下几个公共方法来控制与它关联的Callable任务：

1、boolean cancel(boolean mayInterruptIfRunning)：试图取消Future里关联的Callable任务；

2、V get()：返回Callable任务里call()方法的返回值，调用该方法将导致程序阻塞，必须等到子线程结束以后才会得到返回值；

3、V get(long timeout, TimeUnit unit)：返回Callable任务里call()方法的返回值。该方法让程序最多阻塞timeout和unit指定的时间，如果经过指定时间后，Callable任务依然没有返回值，将会抛出TimeoutException异常；

4、boolean isCancelled()：如果Callable任务正常完成前被取消，则返回true；

5、boolean isDone()：如果Callable任务已经完成，则返回true；

这种方式创建并启动多线程的步骤如下：

1、创建Callable接口实现类，并实现call()方法，该方法将作为线程执行体，且该方法有返回值，再创建Callable实现类的实例；

2、使用FutureTask类来包装Callable对象，该FutureTask对象封装了该Callable对象的call()方法的返回值；

3、使用FutureTask对象作为Thread对象的target创建并启动新线程；

4、调用FutureTask对象的get()方法来获得子线程执行结束后的返回值。

public static void main(String[] args) {

        //这里call()方法的重写是采用lambda表达式，没有新建一个Callable接口的实现类
        FutureTask<Integer> task = new FutureTask<Integer>((Callable<Integer>)()->{
            int i = 0;
            for(;i < 50;i++) {
                System.out.println(Thread.currentThread().getName() +
                        "  的线程执行体内的循环变量i的值为：" + i);
            }
            //call()方法的返回值
            return i;
        });

        for(int j = 0;j < 50;j++) {
            System.out.println(Thread.currentThread().getName() +
                    " 大循环的循环变量j的值为：" + j);
            if(j % 10 == 0) {
                System.out.println("创建线程");
                new Thread(task,"有返回值的线程").start();
            }
        }
        try {
            System.out.println("子线程的返回值：" + task.get());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

本文作者： Cayden
本文链接： http://example.com/2021/07/24/线程、线程池/
版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！