Java多线程Thread详细讲解(万字教程)二

简介: Java多线程Thread详细讲解(万字教程)

Java如何开启线程? 方式2:实现Runnable接口!(详细讲解)


这种方式的本质还是第一种,即Thread类实例调用start方法,从而去调用本地线程资源。因为有且仅有Thread类能通过start0()方法向操作系统申请线程资源(本地方法)!


JVM对于操作系统来说就是一个程序,是一个进程,JVM进程中可以有很多个线程,我们调用start方法其实就是去申请这个线程资源。


Runnable接口:


@FunctionalInterface
public interface Runnable {
    /**
     * When an object implementing interface <code>Runnable</code> is used
     * to create a thread, starting the thread causes the object's
     * <code>run</code> method to be called in that separately executing
     * thread.
     * <p>
     * The general contract of the method <code>run</code> is that it may
     * take any action whatsoever.
     *
     * @see     java.lang.Thread#run()
     */
    public abstract void run();
}


看上面的注释就知道怎么用了,当一个对象实现Runnable接口,你就去创建一个Thread,启动这个Thread,会导致run方法被调用。


我们按照官方的指导来做:


public class MyThread02 implements Runnable{
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "执行了!");
    }
    public static void main(String[] args) {
        new Thread(new MyThread02()).start();
    }
}


看到了吧,这种方式其实还是第一种。不同点在于,第一种方式是直接在Thread子类中重写的Run方法,而这种方式是你自己弄个类,里面有个run方法,传到Thread类中去,最后在Thread类启动的时候,会去调用那个类的run方法。换句话说,如果没有Thread类,这个Runnable实现类是没法自己跑起来的。


所有的秘密就在Thread类的构造函数里面。


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


调了init方法


private void init(ThreadGroup g, Runnable target, String name,long stackSize) {
    init(g, target, name, stackSize, null);
}


又是重载,继续找:


private void init(ThreadGroup g, Runnable target, String name,
                      long stackSize, AccessControlContext acc) {
    //省略其他代码...
    this.target = target;
}

原来,传入的Runnable对象是放到属性target中了。


/* What will be run. */
private Runnable target;


我们再看下Thread类中的run方法:


@Override
public void run() {
   if (target != null) {
        target.run();
   }
}


如果是方式1,这个run方法被重写了,启动start方法的时候就直接调用那个被重写后的run方法了。现在使用方式2的话,就还是调用Thread原生的run方法,做了一个中介,又去调用target的run方法,而target是我们自己传进去的,相当于把具体run的逻辑写到外部一个类里面去了。


以上就是第二种方式的原理,下面介绍一下如何简写代码?


比如,我们可以直接把Runnable实现类用匿名的方式new出来(少些一个类):


public static void main(String[] args) {
    new Thread(new Runnable() {
        @Override
        public void run() {
            System.out.println(Thread.currentThread().getName() + "执行了!");
        }
    }).start();
}


因为Runnable接口只有一个抽象方法,所以还可以直接用Lamda表达式:


new Thread(() -> {
    System.out.println(Thread.currentThread().getName() + "执行了!");
}).start();


6.png


如果还不明白原理,可以看下这张图,安排的明明白白啦。


Java如何开启线程? 方式3:用线程池Executor


什么是线程池:  java.util.concurrent.Executors 提供了一个 java.util.concurrent.Executor 接口的实现用于创建线程池。


一个线程池包括以下四个基本组成部分:

               1、线程池管理器(ThreadPool):用于创建并管理线程池,包括 创建线程池,销毁线程池,添加新任务;

               2、工作线程(PoolWorker):线程池中线程,在没有任务时处于等待状态,可以循环的执行任务;

               3、任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行,它主要规定了任务的入口,任务执行完后的收尾工作,任务的执行状态等;

               4、任务队列(taskQueue):用于存放没有处理的任务。提供一种缓冲机制。


7.png


8.png


线程池的作用:


线程池作用就是限制系统中执行线程的数量。

    根据系统的环境情况,可以自动或手动设置线程数量,达到运行的最佳效果;少了浪费了系统资源,多了造成系统拥挤效率不高。用线程池控制线程数量,其他线程排队等候。一个任务执行完毕,再从队列的中取最前面的任务开始执行。若队列中没有等待进程,线程池的这一资源处于等待。当一个新任务需要运行时,如果线程池中有等待的工作线程,就可以开始运行了;否则进入等待队列。


为什么要用线程池:


1.减少了创建和销毁线程的次数,每个工作线程都可以被重复利用,可执行多个任务。


2.可以根据系统的承受能力,调整线程池中工作线线程的数目,防止因为消耗过多的内存,而把服务器累趴下(每个线程需要大约1MB内存,线程开的越多,消耗的内存也就越大,最后死机)。


Java里面线程池的顶级接口是Executor,但是严格意义上讲Executor并不是一个线程池,而只是一个执行线程的工具。真正的线程池接口是ExecutorService。


微信截图_20230504214123.png


要配置一个线程池是比较复杂的,尤其是对于线程池的原理不是很清楚的情况下,很有可能配置的线程池不是较优的,因此在Executors类里面提供了一些静态工厂,生成一些常用的线程池。


1. newSingleThreadExecutor


创建一个单线程的线程池。这个线程池只有一个线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。


2.newFixedThreadPool


创建固定大小的线程池。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程。


3. newCachedThreadPool


创建一个可缓存的线程池。如果线程池的大小超过了处理任务所需要的线程,


那么就会回收部分空闲(60秒不执行任务)的线程,当任务数增加时,此线程池又可以智能的添加新线程来处理任务。此线程池不会对线程池大小做限制,线程池大小完全依赖于操作系统(或者说JVM)能够创建的最大线程大小。


4.newScheduledThreadPool


创建一个大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。


为了方便演示,我们就创建只有一个线程的线程池:


package com.javaxbfs.thread;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class MyThread03 implements Runnable{
    public static void main(String[] args) throws InterruptedException {
        //创建线程池
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        //提交线程任务-Runnable对象
        Future<?> future = executorService.submit(new MyThread03());
        while(!future.isDone()){
           Thread.sleep(200);
        }
        // 关闭线程池
        executorService.shutdown();
        System.out.println("线程池关闭");
    }
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "========>正在执行!");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "========>执行成功!");
    }
}

效果:


pool-1-thread-1========>正在执行!
pool-1-thread-1========>执行成功!
线程池关闭


这边我们使用的是Runnable对象,线程池还可以接受Callable对象。


package com.javaxbfs.thread;
import java.util.concurrent.*;
public class MyThread04 implements Callable {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        //创建线程池
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        //提交线程任务-Runnable对象
        Future<String> future = executorService.submit(new MyThread04());
        while(!future.isDone()){
           Thread.sleep(200);
        }
        String result = future.get();
        System.out.println("这里拿到线程任务的返回值:" + result);
        // 关闭线程池
        executorService.shutdown();
        System.out.println("线程池关闭");
    }
    @Override
    public String call() {
        System.out.println(Thread.currentThread().getName() + "========>正在执行!");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "========>执行成功!");
        return "SUCCESS";
    }
}


效果:


pool-1-thread-1========>正在执行!
pool-1-thread-1========>执行成功!
这里拿到线程任务的返回值:SUCCESS
线程池关闭


两种方式我都写了例子,关于这个后面还会细说。


总结

1. 不管你是用上面介绍的三种方法的哪一种,都绕不开Thread类,因为只有Thread类的start方法可以去申请本地线程资源!


2. 用Runnable可以把任务代码写在Thread类外面,降低耦合度,更加灵活。


3.Callable一般配合线程池使用,重写的call方法可以添加返回值。


4.线程执行入口永远是Thread类的run方法,这个run方法要么被你重写,要么调用target的run方法,target就是实现runnable接口的对象。



封装Thread类的start方法(经典技巧)


Thread类的start方法是去请求本地资源的,很多源码喜欢把这个细节封装掉,现在让我们来模仿一下这种技巧。


package com.javaxbfs.thread;
public class MyThread05 implements Runnable{
    public void begin(){
        new Thread(this).start();
    }
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "执行了!");
    }
    public static void main(String[] args) {
        MyThread05 myThread05 = new MyThread05();
        myThread05.begin();
    }
}


思路特别简单,不需要你手动去new Thread类了,而是直接在Runnable类中添加begin方法,把这个事情给做了。


相关文章
|
7月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
400 1
|
7月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
375 1
|
7月前
|
Oracle Java 关系型数据库
Java 简单教程
Java是跨平台、面向对象的编程语言,广泛用于企业开发、Android应用等。本教程涵盖环境搭建、基础语法、流程控制、面向对象、集合与异常处理,助你快速入门并编写简单程序,为进一步深入学习打下坚实基础。
572 0
|
8月前
|
安全 Java
Java之泛型使用教程
Java之泛型使用教程
463 10
|
8月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
Java 数据库 Spring
366 0
|
8月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
549 16
|
9月前
|
缓存 并行计算 安全
关于Java多线程详解
本文深入讲解Java多线程编程,涵盖基础概念、线程创建与管理、同步机制、并发工具类、线程池、线程安全集合、实战案例及常见问题解决方案,助你掌握高性能并发编程技巧,应对多线程开发中的挑战。
|
7月前
|
Java 调度 数据库
Python threading模块:多线程编程的实战指南
本文深入讲解Python多线程编程,涵盖threading模块的核心用法:线程创建、生命周期、同步机制(锁、信号量、条件变量)、线程通信(队列)、守护线程与线程池应用。结合实战案例,如多线程下载器,帮助开发者提升程序并发性能,适用于I/O密集型任务处理。
728 0
|
7月前
|
Java
如何在Java中进行多线程编程
Java多线程编程常用方式包括:继承Thread类、实现Runnable接口、Callable接口(可返回结果)及使用线程池。推荐线程池以提升性能,避免频繁创建线程。结合同步与通信机制,可有效管理并发任务。
299 6

热门文章

最新文章