线程的三种创建方式

举报
李子捌 发表于 2021/11/29 08:55:01 2021/11/29
【摘要】 1、Thread继承Thread类,并重写run方法class ThreadDemo1 extends Thread { @Override public void run() { log.info("{}", Thread.currentThread().getName()); }}线程启动方式ThreadDemo1 t1 = new ThreadDemo1();t1.setN...

1、Thread


继承Thread类,并重写run方法

class ThreadDemo1 extends Thread {
  @Override
  public void run() {
    log.info("{}", Thread.currentThread().getName());
  }
}

线程启动方式

ThreadDemo1 t1 = new ThreadDemo1();
t1.setName("t1");
t1.start();

简便写法

Thread t1 = new Thread() {
    @Override
    public void run() {
        log.info("{}", Thread.currentThread().getName());
    }
};
t1.setName("t1");
t1.start();


2、Runnable和Thread

Thread类的构造函数支持传入Runnable的实现类

public Thread(Runnable target) {
    init(null, target, "Thread-" + nextThreadNum(), 0);
}


Thread(Runnable target, AccessControlContext acc) {
    init(null, target, "Thread-" + nextThreadNum(), 0, acc, false);
}

Runnable是一个函数式接口(FunctionalInterface)

@FunctionalInterface
public interface Runnable {
    // 没有返回值
    public abstract void run();
}

因此需要创建类实现Runnable接口,重写run方法

class ThreadDemo2 implements Runnable {

    @Override
    public void run() {
        log.info("{}", Thread.currentThread().getName());
    }
}

简便写法

Thread t2 = new Thread(() -> log.info("{}", Thread.currentThread().getName()), "t2");
t2.start();


3、Callable和Thread

Callable和Runnable一样,也是一个函数式接口,二者的区别非常明显,Runnable中run方法没有返回值,Callable中的run方法有返回值(可以通过泛型约束返回值类型)。因此在需要获取线程执行的返回值时,可以使用Callable。

@FunctionalInterface
public interface Callable<V> {
    // 带返回值
    V call() throws Exception;
}

在Thread的构造函数中,并没有看到Callable,只有Runnable

此时需要一个可以提交Callable给Thread的类,这类就是FutureTask;FutureTask实现类Runnable接口。

并且FutureTask提供了传入Callable的构造函数

public FutureTask(Callable<V> callable) {
    if (callable == null)
        throw new NullPointerException();
    this.callable = callable;
    this.state = NEW;       // ensure visibility of callable
}

因此可以通过FutureTask传入Callable实现,再将FutureTask传给Thread即可

ThreadDemo3 implements Callable<Integer> {

    @Override
    public Integer call() throws Exception {
        log.info("{}", Thread.currentThread().getName());
        return 1998;
    }
}
// Callable 实现类
ThreadDemo3 callable = new ThreadDemo3();
// 通过Callable创建FutureTask
FutureTask<Integer> task = new FutureTask(callable);
// 通过FutureTask创建Thread
Thread t3 = new Thread(task, "t3");
t3.start();

简便写法

Thread t3 = new Thread(new FutureTask<Integer>(() -> {
    log.info("{}", Thread.currentThread().getName());
    return 1998;
}), "t3");
t3.start();


4、三者对比

创建线程的方式有三种,Thread、Runnable+Thread、Callable+FutureTask+Thread;这三者如何选择呢?

  • 首先在实际的开发过程中,我们不会直接创建线程,因为频繁创建和销毁线程开销比较大,此外不利于管理和释放,因此项目中都是通过设计线程池来管理线程资源
  • Thread、Runnable+Thread相比,Runnable+Thread将线程的创建和任务模块解耦了,代码设计更加灵活,此外更加利于任务的提交,更方便和线程池结合使用
  • Callable+FutureTask+Thread适用于需要获取线程返回结果的场景



5、注意项

文中多次使用thread.start();需要注意的是,调用线程的start()方法表示启动线程,但是线程是否执行并不确定,这需要操作系统调度,线程分配到CPU执行时间片才能执行。多核CPU下多个线程同时启动,线程之间交替执行,执行顺序是不确定的。

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。