Java 多线程系列Ⅰ(创建线程+查看线程+Thread方法+线程状态)

简介: Java 多线程系列Ⅰ(创建线程+查看线程+Thread方法+线程状态)

一、创建线程的五种方法

前置知识

  1. Thread 类是用于创建和操作线程的类。每个线程都必须通过 Thread 类的构造方法创建,并实现 run() 方法来执行线程的任务。
  2. run() 方法是 Thread 类中用于定义线程要执行的任务的方法。当一个线程被启动后,它会调用自己的 run() 方法,在该方法中执行线程的任务逻辑。
  3. 需要注意的是,直接调用 run() 方法并不会启动一个新的线程,而只会在当前线程中依次执行 run() 方法中的代码。如果要启动一个新的线程并执行 run() 方法中的代码,应该使用 start() 方法来启动线程。

1、方法一:使用继承Thread类,重写run方法

class MyThread extends Thread {
    //run是线程的入口方法
    @Override
    public void run() {
        System.out.println("Hello t");
    }
}

public class ThreadDemo1 {
    //这种方式是使用Thread 的run来描述线程入口
    public static void main(String[] args) throws InterruptedException {
      // Thread通过接收重写Thread内部run方法的子类
        Thread t = new MyThread();
        // start 启动线程
        t.start();
    }
}

2、方法二:实现Runnable接口,重写run方法

在Java中,Runnable是一个函数式接口(Functional Interface),用于表示要在一个线程中执行的任务。

class MyRunnable implements Runnable {

    @Override
    public void run() {
      System.out.println("hello t");
    }
}

public class ThreadDemo2 {
    public static void main(String[] args) throws InterruptedException {
      // 1.先实例化实现了Runnable接口的类
        MyRunnable runnable = new MyRunnable();
        // 2.通过Thread的构造方法,传入runnable任务,创建线程
        Thread t = new Thread(runnable);
        
        t.start();
    }
}

3、方法三:继承Thread,使用匿名内部类

public class ThreadDemo3 {
    public static void main(String[] args) {
      // 此处的new Thread(){...};就相当于一个继承了Thread类的子类
        Thread t = new Thread(){
            @Override
            public void run() {
                System.out.println("hello t");
            }
        };

        t.start();
    }
}

4、方法四:实现Runnable,使用匿名内部类

public class ThreadDemo4 {
    public static void main(String[] args) {
      // 此处的new Runnable(){...}就相当于一个实现了Runnable接口的类
        Thread t = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("hello t");
            }
        });

        t.start();
    }
}

5、方法五:使用lambda表达式(常用)

虽然上面四种方式都可以达到创建线程的目的,但都不是常用的写法,推荐使用 lambda 表达式是最简单最直观的写法!

回顾lambda表达式

提到 lambda 表达式,下面我们在来回顾一下:


lambda 表达式,本质上就是一个匿名函数。(Java里面,函数(方法)是无法脱离类的,在Java里面 lambda 就相当于是一个例外,它可以将一个函数(或者说方法)作为参数传递到另一个方法中,而不需要将它包含在一个类中。)


虽然说,lambda 表达式可以在⼀定程度上简化接口的实现。但是,并不是所有的接口都可以使用lambda表达式来简洁实现的。lambda 表达式毕竟只是⼀个匿名方法。当实现的接口中的方法过多或者多少的时候,lambda表达式都是不适用的。lambda 表达式,只能实现函数式接口。


函数式接口:如果说,⼀个接口中,要求实现类必须实现的抽象方法,有且只有⼀个,这样的接口,就是函数式接口。

语法规则:

interface Demo {
    public void test();
}
public class Test {
    public static void main(String[] args) {
        // 使用lambda表达式实现接口
        Demo demo = () -> {
            System.out.println("test");
        };
        demo.test();
    }
}

其他规定

  1. ()里面放参数,如果只有一个参数,可以省略 ()
  2. {}里面放函数体,如果只有一行代码,也可以省略 {}
  3. 变量捕获”,lambda 表达式要想访问外面的局部变量,java 要求变量必须是 final 或是 “等效final”(即变量中没有用final修饰,但是代码中并没有做出修改)

使用 lambda 创建线程

public class ThreadDemo5 {
    public static void main(String[] args) throws InterruptedException {
      // lambda本质上是实现了Runnable接口
        Thread t = new Thread(()->{
            System.out.println("hello t");
        });

        t.start();
    }
}

二、体验多线程

运行以下代码体验以下多线程情况下的代码执行。

下面代码中用到了sleep 方法,关于sleep方法说明:

在 Java 中,Thread 类中的 sleep(long millis) 方法用于使当前线程进入休眠状态,暂停执行一段时间。该方法接受一个以毫秒为单位的时间参数,表示要休眠的时间长度。


当线程处于休眠状态时,它不会占用CPU资源,也不会执行任何代码,直到休眠时间结束。在休眠期间,线程可以被中断(通过调用 interrupt() 方法),或者其他线程可以抢占 CPU 资源,使得该线程处于等待状态。

public class ThreadDemo5 {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(()->{
            while (true) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("hello t");
            }
        },"t");

        t.start();
        while (true) {
            Thread.sleep(1000);
            System.out.println("hello main");
        }
    }
}

  1. 上述代码涉及两个线程:(1) main 方法所对应的线程(一个进程中至少有一个线程)也可称为主线程。(2) t 线程
  2. 运行程序,其实就是idea对应的进程创建了一个新的 java进程,这个java进程用来执行自己写的代码。同时这个 java进程里有两个线程,一个是main,一个是t,每个线程都是一个独立的执行流。此时的 hello t 是由 t 线程执行的打印逻辑。
  3. 这里的交替打印并不是严格意义上的交替,每一秒过后,先打印main还是先打印 t 是不确定的,因为多个线程在 CPU 上调度执行的顺序是不确定的(随机的)。


查看线程详情

我们可以使用 jdk 提供的第三方工具,查看java进程里面的线程详情:

注意事项:

  1. jconsole 只能分析 Java 进程。
  2. 运行就 jconsole,如果进程列表为空,可以尝试以管理员身份运行。

点进当前代码的进程对应的线程:

三、Thread及常见方法

Thread 类是 JVM 用来管理线程的一个类,换句话说,每个线程都有一个唯一的 Thread 对象与之关联,即Java代码中的Thread对象和操作系统中的线程是一一对应的。而 Thread 类的对象就是用来描述一个线程执行流的,JVM 会将这些 Thread 对象组织起来,用于线程调度,线程管理。

1、构造方法

方法 说明
Thread() 创建线程对象
Thread(Runnable target) 使用 Runnable 对象创建线程对象
Thread(String name) 创建线程对象,并命名
Thread(Runnable target, String name) 使用 Runnable 对象创建线程对象,并命名

注意:name 名字参数,是给线程起了个名字,这里的名字不影响程序的执行,只是方便我们在调试的时候,快速找到需要的线程。

2、线程属性获取方法

返回值类型 方法名 说明
long getId() 返回线程标识符Id
String getName() 返回线程名称
Thread.State getState() 返回线程状态
int getPriority() 返回线程优先级
boolean isDaemon() 判断是否为后台线程
boolean isAlive() 判断线程是否存活
boolean isInterrupted() 判断线程是否被中断

(1)isDaemon()-前台线程后台线程说明:

  1. isDaemon()返回true-表示后台线程,后台线程不阻止Java进程结束,哪怕后台线程还没执行完,Java进程该结束就结束。
  1. isDaemon()返回false-表示前台线程,前台线程会阻止Java进程结束,必须得Java进程中所有的前台线程执行完Java进程才能结束。

    注:创建的线程默认是前台的,可以通过setDaemon(true)设置成后台的。

(2)isAlive()线程存活说明

描述的是系统内核里哪个线程是否存活,也就是说只有调用start()方法(调用 start 方法,

才真的在操作系统的底层创建出一个线程),启动线程之后,当线程正在执行时返回true,否则返回false

(3)isInterrupted()后面详细介绍…

3、启动线程-start()

上面介绍的五种创建线程的方式,都是通过覆写 run() 方法创建一个线程对象,但线程对象被创建出来并不意味着线程就开始运行了。只有调用了start()方法,才真正从系统这里创建一个线程。

调用 start 方法, 才真的在操作系统的底层创建出一个线程

4、中断一个线程:(让一个线程停下来)

中断一个线程,就是让一个线程停下来,即线程终止,本质上来说,线程终止就是让该线程的入口方法执行完毕。这里的执行完毕可以是 return 返回代码执行完毕抛出异常 等情况。具体来说,可以采取如下策略:

(1)给线程设置一个结束标志位

例如:设置标志位isQuite作为线程结束的标志

public class ThreadExample_Interrupted {
    // 由于"变量捕获",这里将isQuite设置为成员变量
    public static boolean isQuite = false;

    public static void main(String[] args) {
        Thread t = new Thread(()->{
            while (!isQuite) {
                System.out.println("hello t");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("t线程终止");
        });

        t.start();

        // 3秒后,在主线程中修改isQuite
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        isQuite = true;

    }
}

注意:这种情况下是将isQuite设置成了成员变量,如果将其设置成局部变量,正常情况下由于线程和线程之间共用一个内存地址空间,语法上是成立的,但是对于lambda表达式要是想要访问外面的局部变量,这时就涉及到了Java变量捕获,即捕获的变量必须是 final 或者 “等效final”,即变量中没有用final修饰,但是代码中并没有做出修改。

(2)使用Thread类内置的标志位

方法名称 说明
public static Thread currentThread() 返回对当前正在执行的线程对象的引用。
public void interrupt() 中断对象关联的线程。如果线程正在阻塞,则以异常方式通知,否则设置标志位true。
public static boolean interrupted() 判断当前线程的中断标志位是否设置,调用后清除标志位。
public boolean isInterrupted() 判断对象关联的线程的标志位是否设置,调用后不清除标志位。

Thread 内部包含了一个 boolean 类型的变量作为线程是否被中断的标记。根据上述提供的方法,我们可以使用 Thread.interrupted() 或者 Thread.currentThread().isInterrupted() 代替自定义标志位。

例如:还是上面的例子,这次我们使用内置标志位

public class ThreadExample_Interrupted2 {
    public static void main(String[] args) {
        Thread t = new Thread(()->{

            // 此处 currentThread currentThread 是获取到当前线程实例 t
            while (!Thread.currentThread().isInterrupted()) {
                System.out.println("hello t");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        t.start();
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 将内部的标志位设置成true
        t.interrupt();
    }
}

注意:通过上面结果,我们看到,即使sleep被强制唤醒后,触发了两件事:

  1. 如果线程因为调用 wait/join/sleep 等方法而阻塞挂起,则以 InterruptedException异常的形式通知.
  2. 清除中断标志.

因此我们会看到,抛出异常后,t 线程中的循环继续进行(因为此时sleep被唤醒后清空了标志位 true->false)


对于 interrupt 只是通知不是命令,至于为什么 Java 不强制设置成“命令结束”的操作,主要是因为,这种强制性的设定是非常不友好的,对于线程 线程何时结束,始终是线程本身最清楚,所以还是交给线程自身来决定比较好。

5、等待一个线程-join()

线程之间是并发执行的,操作系统对于线程的调度是无序的,无法判断两个线程谁先执行结束,谁后执行结束。然而有时候有需要明确规定线程的结束顺序,这时就可以使用线程等待-join来实现。

方法 说明
public void join() 等待线程结束
public void join(long millis) 等待线程结束,最多等 millis 毫秒。

例如:我们需要等待一个线程t完成它打印工作后,才能进行main线程的打印工作。

public class ThreadExample_join {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(() -> {
            for (int i = 0; i < 5; i++) {
                System.out.println("hello t");
            }
        });

        t.start();
        // 正常情况下,如果不加join,大部分情况下是先打印hello main(因为创建线程也是需要开销的)
        t.join();//这里就使t线程先执行完,main暂时阻塞
        System.out.println("hello main");
    }
}

05150e0b39894263ab68b83042207361.png

上述代码在main线程中调用 t.join:如果 t 线程还没结束,main 线程就会“阻塞”等待-Blocking。也就是说代码执行到 t.join 时就停下来了,当前这个线程暂时不参与CPU的调度执行了。直到 t 线程执行完毕,此时 main 解除阻塞后将继续向下执行。


四、线程的状态

操作系统中的线程,自身是有一个状态的,但是Java 中Thread是对系统线程的封装,将里面的状态进一步精细化了。

  • NEW :系统中的线程还没创建出来,但是有个 Thread 对象
  • RUNNABLE: 就绪状态(1.正在CPU上执行 2.准备好随时可以去CPU上运行)
  • TERMINATED: 系统中的线程已经执行完了,Thread对象还在
  • TIMED_WAITING: 指定时间等待
  • BLOCKED :等待锁出现的状态
  • WAITING :使用 wait、join 方法出现的状态


相关文章
|
11天前
|
安全 Java 测试技术
Java并行流陷阱:为什么指定线程池可能是个坏主意
本文探讨了Java并行流的使用陷阱,尤其是指定线程池的问题。文章分析了并行流的设计思想,指出了指定线程池的弊端,并提供了使用CompletableFuture等替代方案。同时,介绍了Parallel Collector库在处理阻塞任务时的优势和特点。
|
7天前
|
安全 Java 开发者
深入解读JAVA多线程:wait()、notify()、notifyAll()的奥秘
在Java多线程编程中,`wait()`、`notify()`和`notifyAll()`方法是实现线程间通信和同步的关键机制。这些方法定义在`java.lang.Object`类中,每个Java对象都可以作为线程间通信的媒介。本文将详细解析这三个方法的使用方法和最佳实践,帮助开发者更高效地进行多线程编程。 示例代码展示了如何在同步方法中使用这些方法,确保线程安全和高效的通信。
27 9
|
10天前
|
存储 安全 Java
Java多线程编程的艺术:从基础到实践####
本文深入探讨了Java多线程编程的核心概念、应用场景及其实现方式,旨在帮助开发者理解并掌握多线程编程的基本技能。文章首先概述了多线程的重要性和常见挑战,随后详细介绍了Java中创建和管理线程的两种主要方式:继承Thread类与实现Runnable接口。通过实例代码,本文展示了如何正确启动、运行及同步线程,以及如何处理线程间的通信与协作问题。最后,文章总结了多线程编程的最佳实践,为读者在实际项目中应用多线程技术提供了宝贵的参考。 ####
|
7天前
|
监控 安全 Java
Java中的多线程编程:从入门到实践####
本文将深入浅出地探讨Java多线程编程的核心概念、应用场景及实践技巧。不同于传统的摘要形式,本文将以一个简短的代码示例作为开篇,直接展示多线程的魅力,随后再详细解析其背后的原理与实现方式,旨在帮助读者快速理解并掌握Java多线程编程的基本技能。 ```java // 简单的多线程示例:创建两个线程,分别打印不同的消息 public class SimpleMultithreading { public static void main(String[] args) { Thread thread1 = new Thread(() -> System.out.prin
|
10天前
|
Java
JAVA多线程通信:为何wait()与notify()如此重要?
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是实现线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件满足时被唤醒,从而确保数据一致性和同步。相比其他通信方式,如忙等待,这些方法更高效灵活。 示例代码展示了如何在生产者-消费者模型中使用这些方法实现线程间的协调和同步。
24 3
|
8天前
|
安全 Java
Java多线程集合类
本文介绍了Java中线程安全的问题及解决方案。通过示例代码展示了使用`CopyOnWriteArrayList`、`CopyOnWriteArraySet`和`ConcurrentHashMap`来解决多线程环境下集合操作的线程安全问题。这些类通过不同的机制确保了线程安全,提高了并发性能。
|
9天前
|
Java
java小知识—进程和线程
进程 进程是程序的一次执行过程,是系统运行的基本单位,因此进程是动态的。系统运行一个程序即是一个进程从创建,运行到消亡的过程。简单来说,一个进程就是一个执行中的程序,它在计算机中一个指令接着一个指令地执行着,同时,每个进程还占有某些系统资源如CPU时间,内存空间,文件,文件,输入输出设备的使用权等等。换句话说,当程序在执行时,将会被操作系统载入内存中。 线程 线程,与进程相似,但线程是一个比进程更小的执行单位。一个进程在其执行的过程中产生多个线程。与进程不同的是同类的多个线程共享同一块内存空间和一组系统资源,所以系统在产生一个线程,或是在各个线程之间做切换工作时,负担要比
21 1
|
10天前
|
Java UED
Java中的多线程编程基础与实践
【10月更文挑战第35天】在Java的世界中,多线程是提升应用性能和响应性的利器。本文将深入浅出地介绍如何在Java中创建和管理线程,以及如何利用同步机制确保数据一致性。我们将从简单的“Hello, World!”线程示例出发,逐步探索线程池的高效使用,并讨论常见的多线程问题。无论你是Java新手还是希望深化理解,这篇文章都将为你打开多线程的大门。
|
13天前
|
存储 Java 程序员
Java基础的灵魂——Object类方法详解(社招面试不踩坑)
本文介绍了Java中`Object`类的几个重要方法,包括`toString`、`equals`、`hashCode`、`finalize`、`clone`、`getClass`、`notify`和`wait`。这些方法是面试中的常考点,掌握它们有助于理解Java对象的行为和实现多线程编程。作者通过具体示例和应用场景,详细解析了每个方法的作用和重写技巧,帮助读者更好地应对面试和技术开发。
53 4
|
10天前
|
安全 Java 编译器
Java多线程编程的陷阱与最佳实践####
【10月更文挑战第29天】 本文深入探讨了Java多线程编程中的常见陷阱,如竞态条件、死锁、内存一致性错误等,并通过实例分析揭示了这些陷阱的成因。同时,文章也分享了一系列最佳实践,包括使用volatile关键字、原子类、线程安全集合以及并发框架(如java.util.concurrent包下的工具类),帮助开发者有效避免多线程编程中的问题,提升应用的稳定性和性能。 ####
38 1