线程--创建线程的几种方式及源码分析

Posted 2020-10-10 傲视苍穹

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了线程--创建线程的几种方式及源码分析相关的知识，希望对你有一定的参考价值。

线程--创建线程的几种方式及源码分析

开始整理下线程的知识，感觉这块一直是盲区，工作中这些东西一直没有实际使用过，感觉也只是停留在初步的认识。前段时间一个内推的面试被问到，感觉一脸懵逼。面试官说，我的回答都是百度的第一页，有时间往第二页看看。废话停止，进入正题。

一、创建线程的常用方式：继承Thread类，实现Runnable接口，通过Callable和Future创建线程；

1、继承Thread类创建线程类

（1）定义Thread类的子类，并重写该类的run方法，该run方法的方法体就代表了线程要完成的任务。因此把run()方法称为执行体。

（2）创建Thread子类的实例，即创建了线程对象。

（3）调用线程对象的start()方法来启动该线程。

package com.cqfczc.util;

public class FirstThreadTest extends Thread{
　　int i = 0;
　　//重写run方法，run方法的方法体就是现场执行体
　　public void run(){
　　for(;i<100;i++){
　　System.out.println(Thread.currentThread().getName()+" "+i);
　　}
}
public static void main(String[] args){
　　for(int i = 0;i< 100;i++) {
　　　　System.out.println(Thread.currentThread().getName()+" : "+i);
　　　　if(i==20) {
　　　　　　new FirstThreadTest().start();
　　　　　　new FirstThreadTest().start();
　　　　}
　　}
}
}

思考：为什么要继承Thread，继承后为何会调用到我们写的run方法，执行顺序是否正常？

解答：1、因为Thread类是Java类库提供给我们的一个创建线程调用类，我们要创建一个线程只能继承它，因为Java的API提供的类库是遵循“禁止修改、开发扩展”的原则。我们不能直接修改Thread类中的方法，只能通过继承来扩展父类中的方法；2、当子类重写父类的方法后执行时是优先调用子类中的方法，若没有重写则调用父类的方法，这是Java的基本语法不用多说；3、打印结果可以说明执行顺序是凌乱无规则的，在上面的代码中，只能保证每个线程都将启动，每个线程都将运行直到完成。一系列线程以某种顺序启动并不意味着将按该顺序执行。对于任何一组启动的线程来说，调度程序不能保证其执行次序，持续时间也无法保证。

java.lang.Thread类中有个run()方法如图所示：

如果该线程是使用独立的Runnable运行对象构造的，则调用该Runnable对象的run方法；否则，该方法不执行任何操作。图中的targer就是一个Runable实现类；由此我们分析可知，若不出创建Runnable对象，只能继承Thread类并且覆盖父类的run方法线程执行时才会有效果。

2、实现Runnable接口创建线程类

（1）定义runnable接口的实现类，并重写该接口的run()方法，该run()方法的方法体同样是该线程的线程执行体。

（2）创建 Runnable实现类的实例，并依此实例作为Thread的target来创建Thread对象，该Thread对象才是真正的线程对象。

（3）调用线程对象的start()方法来启动该线程。

public class RunnableThreadTest implements Runnable{
　　private int i;
　　public void run() {
　　　　for(i = 0;i <100;i++) {
　　　　System.out.println(Thread.currentThread().getName()+" "+i);
　　　　}
　　}
　　public static void main(String[] args) {
　　　　for(int i = 0;i < 100;i++) {
　　　　　　System.out.println(Thread.currentThread().getName()+" "+i);
　　　　　　if(i==20) {
　　　　　　　　RunnableThreadTest rtt = new RunnableThreadTest();
　　　　　　　　new Thread(rtt,"新线程1").start();
　　　　　　　　new Thread(rtt,"新线程2").start();
　　　　　　}
　　　　}

　　}
}

思考：为何实现Runnable即可创建线程，执行run方法体？

解答：我们直接看Thread类的源码即可明白，Thread这个类也是实现Runnable接口并且实现了run方法；

此处就不用做过多的解释了，看到上面的源码截图肯定都理解了。只是我们实现了Runnable接口后只用run方法，没有配合操作线程的方法，因此我们需要构造一个Thread对象，并将实现类放进去才能执行操作。到此处大家应该彻底明白为何我们实现了Runnable接口后，必须要把这个实现类再到Thread类中了。

三、通过Callable和Future创建线程

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

（2）创建Callable实现类的实例，使用FutureTask类来包装Callable对象，该FutureTask对象封装了该Callable对象的call()方法的返回值。

（3）使用FutureTask对象作为Thread对象的target创建并启动新线程。

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

public class CallableThreadTest implements Callable<Integer>{
　　public static void main(String[] args) {
　　　　CallableThreadTest ctt = new CallableThreadTest();
　　　　FutureTask<Integer> ft = new FutureTask<>(ctt);
　　　　for(int i = 0;i < 100;i++) {
　　　　　　System.out.println(Thread.currentThread().getName()+" 的循环变量i的值"+i);
　　　　　　if(i==20) {
　　　　　　　　new Thread(ft,"有返回值的线程").start();
　　　　　　}
　　　　}
　　　　try {
　　　　　　System.out.println("子线程的返回值："+ft.get());
　　　　} catch (InterruptedException e) {
　　　　　　e.printStackTrace();
　　　　} catch (ExecutionException e) {
　　　　　　e.printStackTrace();
　　　　}
　　}
　　@Override
　　public Integer call() throws Exception {
　　　　int i = 0;
　　　　for(;i<100;i++) {
　　　　　　System.out.println(Thread.currentThread().getName()+" "+i);
　　　　}
　　　　return i;
　　}
}