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 方法出现的状态


相关文章
|
1天前
|
Java
Java—多线程实现生产消费者
本文介绍了多线程实现生产消费者模式的三个版本。Version1包含四个类:`Producer`(生产者)、`Consumer`(消费者)、`Resource`(公共资源)和`TestMain`(测试类)。通过`synchronized`和`wait/notify`机制控制线程同步,但存在多个生产者或消费者时可能出现多次生产和消费的问题。 Version2将`if`改为`while`,解决了多次生产和消费的问题,但仍可能因`notify()`随机唤醒线程而导致死锁。因此,引入了`notifyAll()`来唤醒所有等待线程,但这会带来性能问题。
Java—多线程实现生产消费者
|
3天前
|
安全 Java Kotlin
Java多线程——synchronized、volatile 保障可见性
Java多线程中,`synchronized` 和 `volatile` 关键字用于保障可见性。`synchronized` 保证原子性、可见性和有序性,通过锁机制确保线程安全;`volatile` 仅保证可见性和有序性,不保证原子性。代码示例展示了如何使用 `synchronized` 和 `volatile` 解决主线程无法感知子线程修改共享变量的问题。总结:`volatile` 确保不同线程对共享变量操作的可见性,使一个线程修改后,其他线程能立即看到最新值。
|
3天前
|
消息中间件 缓存 安全
Java多线程是什么
Java多线程简介:本文介绍了Java中常见的线程池类型,包括`newCachedThreadPool`(适用于短期异步任务)、`newFixedThreadPool`(适用于固定数量的长期任务)、`newScheduledThreadPool`(支持定时和周期性任务)以及`newSingleThreadExecutor`(保证任务顺序执行)。同时,文章还讲解了Java中的锁机制,如`synchronized`关键字、CAS操作及其实现方式,并详细描述了可重入锁`ReentrantLock`和读写锁`ReadWriteLock`的工作原理与应用场景。
|
4天前
|
存储 安全 Java
Java多线程编程秘籍:各种方案一网打尽,不要错过!
Java 中实现多线程的方式主要有四种:继承 Thread 类、实现 Runnable 接口、实现 Callable 接口和使用线程池。每种方式各有优缺点,适用于不同的场景。继承 Thread 类最简单,实现 Runnable 接口更灵活,Callable 接口支持返回结果,线程池则便于管理和复用线程。实际应用中可根据需求选择合适的方式。此外,还介绍了多线程相关的常见面试问题及答案,涵盖线程概念、线程安全、线程池等知识点。
45 2
|
27天前
|
设计模式 Java 开发者
Java多线程编程的陷阱与解决方案####
本文深入探讨了Java多线程编程中常见的问题及其解决策略。通过分析竞态条件、死锁、活锁等典型场景,并结合代码示例和实用技巧,帮助开发者有效避免这些陷阱,提升并发程序的稳定性和性能。 ####
|
27天前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱,如竞态条件、死锁和内存一致性错误,并提供了实用的避免策略。通过分析典型错误案例,本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧,从而提升并发程序的稳定性和性能。 ####
|
20天前
|
安全 算法 Java
Java多线程编程中的陷阱与最佳实践####
本文探讨了Java多线程编程中常见的陷阱,并介绍了如何通过最佳实践来避免这些问题。我们将从基础概念入手,逐步深入到具体的代码示例,帮助开发者更好地理解和应用多线程技术。无论是初学者还是有经验的开发者,都能从中获得有价值的见解和建议。 ####
|
20天前
|
Java 调度
Java中的多线程编程与并发控制
本文深入探讨了Java编程语言中多线程编程的基础知识和并发控制机制。文章首先介绍了多线程的基本概念,包括线程的定义、生命周期以及在Java中创建和管理线程的方法。接着,详细讲解了Java提供的同步机制,如synchronized关键字、wait()和notify()方法等,以及如何通过这些机制实现线程间的协调与通信。最后,本文还讨论了一些常见的并发问题,例如死锁、竞态条件等,并提供了相应的解决策略。
43 3
|
26天前
|
缓存 Java 开发者
Java多线程并发编程:同步机制与实践应用
本文深入探讨Java多线程中的同步机制,分析了多线程并发带来的数据不一致等问题,详细介绍了`synchronized`关键字、`ReentrantLock`显式锁及`ReentrantReadWriteLock`读写锁的应用,结合代码示例展示了如何有效解决竞态条件,提升程序性能与稳定性。
112 6
|
26天前
|
安全 Java 开发者
Java中的多线程编程:从基础到实践
本文深入探讨了Java多线程编程的核心概念和实践技巧,旨在帮助读者理解多线程的工作原理,掌握线程的创建、管理和同步机制。通过具体示例和最佳实践,本文展示了如何在Java应用中有效地利用多线程技术,提高程序性能和响应速度。
60 1