多线程(Thread类、线程创建、中断、等待、休眠)

简介: 多线程(Thread类、线程创建、中断、等待、休眠)

前言:  


一、什么是进程?


正在运行的程序的实例

       在操作系统没有引入进程的时候,CPU每次只能执行一个程序多个程序只能顺序执行,这样就造成了资源的浪费浪费了大量的时间,为了提高CPU的利用率于是操作系统引入了进程以及中断处理,这样就实现了通一时间内可以运行多个程序提高效率。

资源分配基本单位

二、什么是线程?


进程的实际运行最小单位

       进程虽然实现了并发编程但是平凡创建进程的开销较大,引入的线程是轻量级的进程,可以减少开销提高效率。

调度执行的基本单位

一、线程创建:


  1. 继承Thread类实现的run方法
  2. 实现Runnable接口重写里面run方法
  3. 继承Thread类实现run方法,匿名内部类实现
  4. 使用匿名内部类重写run方法
  5. lambda表达式

继承Thread类实现的run方法


class MyTread extends Thread {
    public void run() {
        while (true) {
            System.out.println("Hello Thread ");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
    }
}
public class Demo1 {
    public static void main(String[] args) throws InterruptedException {
        MyTread myTread = new MyTread();
        myTread.start();
        while ( true) {
            System.out.println("Hello main");
            Thread.sleep(1000);
        }
    }
}

实现Runnable接口重写里面run方法


class MyRunnable implements Runnable{
    @Override
    public void run() {
        while (true) {
            System.out.println("Hello Runnable");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
        }
}
public class Demo2 {
    public static void main(String[] args) throws InterruptedException {
        MyRunnable myRunnable = new MyRunnable();
        Thread t = new Thread(myRunnable);
        t.start();
        while (true) {
            System.out.println("Hello main");
            Thread.sleep(1000);
        }
    }
}

继承Thread类实现run方法,匿名内部类实现


public class Demo3 {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread() {
            public void run() {
                while (true) {
                    System.out.println("Hello Thread");
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        };
        t.start();
        while (true) {
            System.out.println("Hello main");
            Thread.sleep(1000);
        }
    }
}

使用匿名内部类重写run方法


public class Demo4 {
    public static void main(String[] args) {
        Thread t = new Thread(new Runnable() {
            @Override
            public void run() {
                while (true) {
                    System.out.println("Hello Thread");
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        });
        t.start();
        while (true) {
            System.out.println("Hello main");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
    }

lambda表达式


public class Demo5 {
    public static void main(String[] args) {
        Thread t = new Thread(() -> {
            while (true) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("Hello Thread");
            }
        });
        t.start();
    }
}


二、线程中断


常用三个方法

public void interrup()

作用:中断调用方法的线程,调用方法后线程仍然运行,只是标志位改为true(中断状态)

public static boolean interred()

作用:检测当前线程是否中断,返回一个boolean并且清除当前线程状态,第二次调用返回false

public boolean isInterrupted()

作用:检测调用方法的线程是否中断,不清除状态

三、线程等待


public void join()

image.png

编辑

大家看下这个例子:

public class test {
    public static final long count = 10_0000_0000L;
    public static void main(String[] args) throws InterruptedException {
        serial();
        long begin =System.currentTimeMillis();
        Thread t1 = new Thread(() ->{
            long a =0;
            for (long i = 0; i < count; i++) {
                a++;
            }
        });
        Thread t2 = new Thread(() ->{
            long a = 0;
            for (long i = 0; i < count; i++) {
                a++;
            }
        });
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        long end = System.currentTimeMillis();
        System.out.println("多线程时间:" + (end-begin));
    }
    public static void serial() {
        long a =0;
        long begin = System.currentTimeMillis();
        for (int i = 0; i < count; i++) {
            a++;
        }
        a=0;
        for (int i = 0; i < count; i++) {
            a++;
        }
        long end = System.currentTimeMillis();
        System.out.println("单线程所用时间:" +(end - begin));
    }

这里面使用了t1.join()和t2.join(),作用是让当前线程(这里是main主线程)等待使用join方法的线程执行完成再进行当前线程。join方法会将当前线程从执行的线程中挂起,挂到等待队列中等到线程执行完成后再从等待队列加入到执行队列中。

image.png

编辑补充:

使用带参数的join方法叫做期限等待(TIME_WAITING):在这种状态下不会被CPU分配执行实现,无需等待被其他线程显式唤醒,在时间结束后即可自动唤醒。

四、线程休眠


sleep() 定义在Thread.java中。

sleep() 的作用是让当前线程休眠,即当前线程会从“运行状态”进入到“休眠(阻塞)状态”。sleep()会指定休眠时间,线程休眠的时间会大于/等于该休眠时间;在线程重新被唤醒时,它会由“阻塞状态”变成“就绪状态”,从而等待cpu的调度执行。线程在休眠期间会让出cpu资源。在线程休眠之后,可以在任意时间对线程进行唤醒。

五、线程状态


新建(NEW):创建出线程但是没有启用。

运行状态(RUNNABLE):调用start方法启用线程,此时线程实在执行状态

无限等待状态(WATING):这种状态下不会被CPU分配执行时间,等到被唤醒。

无Timeout参数的Object.wait()方法

无Timeout参数的Thread.join()方法

LockSupport.park()方法

期限等待(TIME_WAITING):在这种状态下不会被CPU分配执行实现,无需等待被其他线程显式唤醒,在时间结束后即可自动唤醒。

堵塞状态(BLOCKED):线程被堵塞

结束(TERMINATED):线程执行结束

相关文章
|
8月前
|
安全 算法 Java
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
360 0
|
5月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
281 1
|
5月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
300 1
|
8月前
|
数据采集 监控 调度
干货分享“用 多线程 爬取数据”:单线程 + 协程的效率反超 3 倍,这才是 Python 异步的正确打开方式
在 Python 爬虫中,多线程因 GIL 和切换开销效率低下,而协程通过用户态调度实现高并发,大幅提升爬取效率。本文详解协程原理、实战对比多线程性能,并提供最佳实践,助你掌握异步爬虫核心技术。
|
9月前
|
Java 数据挖掘 调度
Java 多线程创建零基础入门新手指南:从零开始全面学习多线程创建方法
本文从零基础角度出发,深入浅出地讲解Java多线程的创建方式。内容涵盖继承`Thread`类、实现`Runnable`接口、使用`Callable`和`Future`接口以及线程池的创建与管理等核心知识点。通过代码示例与应用场景分析,帮助读者理解每种方式的特点及适用场景,理论结合实践,轻松掌握Java多线程编程 essentials。
649 5
|
5月前
|
Java
如何在Java中进行多线程编程
Java多线程编程常用方式包括:继承Thread类、实现Runnable接口、Callable接口(可返回结果)及使用线程池。推荐线程池以提升性能,避免频繁创建线程。结合同步与通信机制,可有效管理并发任务。
248 6
|
8月前
|
Java API 微服务
为什么虚拟线程将改变Java并发编程?
为什么虚拟线程将改变Java并发编程?
399 83
|
10月前
|
机器学习/深度学习 消息中间件 存储
【高薪程序员必看】万字长文拆解Java并发编程!(9-2):并发工具-线程池
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发编程中的强力并发工具-线程池,废话不多说让我们直接开始。
390 0
|
5月前
|
Java 调度 数据库
Python threading模块:多线程编程的实战指南
本文深入讲解Python多线程编程,涵盖threading模块的核心用法:线程创建、生命周期、同步机制(锁、信号量、条件变量)、线程通信(队列)、守护线程与线程池应用。结合实战案例,如多线程下载器,帮助开发者提升程序并发性能,适用于I/O密集型任务处理。
524 0
|
6月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
452 16

热门文章

最新文章