Java 多线程编程(入门)

简介: Java 多线程编程(入门)

一、简单介绍 Thread类

       线程是操作系统的概念。操作系统给线程的一些相关操作,提供了一系列的API让用户使用(例如 Linux 的 pthread 库)。

       这些系统原生的 API 是用 C语言编写的,而Java 为了能够方便使用这些 API, 就把这些 API 给封装成 Java 风格的类。

这个类就是 Java标准库中的 Thread 类

Thread 类可以视为是对操作系统提供的 API 进行了进一步的封装和抽象

【1】Thread类中一些常用的方法

  🌑start 方法

调用 start() 方法用来启动一个线程。当我们创建一个线程后,只有调用 start() 方法才能启动,并执行一些任务。

  🌒run 方法

run() 方法是不需要用户调用的。run() 方法相当于线程他的本质工作,当线程通过 start() 启动后,线程会自动执行 run() 内的任务。

注意:继承Thread类时,必须重写run方法,在run方法内自定义要执行的任务

🌓sleep 方法

1. sleep(long ms) //参数为毫秒
2. sleep(long ms,int nanoseconds)//第一个参数为毫秒,第二个参数为纳秒

sleep() 方法相当于让线程休眠

注意:使用 sleep方法是要处理一下异常!

【2】编写一个简单多线程程序(入门)

如果我们想创建一个线程并让它不断打印 “hello world”的任务。

首先:我们可以自己创建一个线程类(MyThread) 继承 Thread 类


第二步:重写 run() 方法,把我们想要线程执行的任务写入 run() 方法内部,如下

class MyThread extends Thread{
    @Override
    public void run() {
        System.out.println("hello thread!");
    }
}

第三步:在 main函数中创建名为 MyThread的线程,并调用 start() 方法启动该线程

public class Demo1 {
    public static void main(String[] args){
        MyThread myThread = new MyThread();
        myThread.start();
    }
}

这样我们就创建了一个线程啦。

在 Java 中,一个 Java 程序相当于一个进程,而 main函数相当于 主线程。我们创建的线程 和 主线程都是属于进程!!

每个线程都是一个独立的执行流

多个线程之间是 “并发” 执行的

  为了方便观察多线程的执行法过程,我们在 main函数 中也写上打印任务,并分别调用 sleep 方法,方便我们观察。

package threading;
class MyThread extends Thread{
    @Override
    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 {
        MyThread myThread = new MyThread();
        myThread.start();
        while(true){
            System.out.println("hello main");
            Thread.sleep(1000);
        }
    }
}

结果如下:

   

我们会发现 main主线程 和 我们创建的线程是并发执行的(并发+并行),并不是串行执行的。

我们还可以使用 jconsole 命令观察线程

jconsole 命令查找可以查看:使用 jconsole 命令观察线程


jconsole 命令查找可以查看:使用 jconsole 命令观察线程

二、Java中创建多线程的方法(重点面试题)

1.继承 Thread 类

上述给大家演示的代码就是继承 Thread 类创建线程的方法,这里就不再赘述了。

2.实现 Runnable 接口,重写 run

先创建一个实现 Runnable 接口的类,实例化后作为参数传递给 Thread 构造方法。

class MyRunnable implements Runnable{
    @Override
    public void run() {
        while(true){
            ...
        }
    }
}
public class Demo2 {
    public static void main(String[] args) {
        MyRunnable runnable = new MyRunnable();
        Thread t = new Thread(runnable);
        t.start();
        while(true){
            System.out.println("hello main");
        }
    }
}

把任务提取出来,目的仍然是为了 解耦合 !

前面继承Thread 协防,就把线程要完成的工作,和线程本身,耦合在一起了

假设未来要对这个代码进程调整(不用多线程了,用其他方式),代码改动就比较大


而 Runnable 这种写法,就只是需要把 Runnable 传给其他的实体即可!!

3.使用匿名内部类,实现 创建 Thread 子类的方式

package threading;
public class Demo3 {
    public static void main(String[] args) {
        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();
    }
}

4.使用匿名内部类,实现 Runnable 接口的方法

在 Thread 的构造方法的参数里面就地创建了一个匿名内部类

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();
    }
}

匿名内部类的实例,作为构造方法的参数

5.lambda 表达式【推荐】

lambda 本质上是一个 “匿名函数”

语法格式如下:

 Thread t = new Thread(()->{
    //... 
 });

():内代表函数的形参  {}:代表函数体

-> 特殊语法,表示它是一个 lambda

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

注意:创建线程并不知道以上五种方式,不过大家知道这些就已经足够了

三、简单分析多线程编程提升效率

观察多线程在一些场合下,并行执行提升的代码运行速度的效率

System.currentTimeMillis():获取当前的时间戳。

serial 串行的完成一下运算,concurrency  使用两个线程并行执行相同操作。

package threading;
public class Demo6 {
    public static final long COUNT = 10_0000_0000L;
    public static void main(String[] args) throws InterruptedException {
        serial();
        concurrency();
    }
    // 串行执行任务
    public static void serial(){
        // 记录 ms 级别的时间戳
        long beg = System.currentTimeMillis();
        long a = 0;
        for(long i = 0;i < COUNT;i++){
            a++;
        }
        a= 0;
        for (int i = 0; i < COUNT; i++) {
            a++;
        }
        long end = System.currentTimeMillis();
        System.out.println("执行的时间间隔" + (end - beg) + " ms");
    }
    // 并发执行任务
    public static void concurrency() throws InterruptedException {
        long beg = System.currentTimeMillis();
        Thread t1 = new Thread(() -> {
            long a = 0;
            for (int i = 0; i < COUNT; i++) {
                a++;
            }
        });
        Thread t2 = new Thread(() -> {
            long a = 0;
            for (int i = 0; i < COUNT; i++) {
                a++;
            }
        });
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        long end = System.currentTimeMillis();
        System.out.println("执行的时间间隔" + (end - beg) + " ms");
    }
}

 在main 中调用 t1.join() 效果就是让 main 线程阻塞,一直到 t1 执行完 run , mian才继续执行!!

由结果可知,在相同运算操作下,并行执行大致能比串行执行快1倍左右。但是并行执行提升代码速度并不是没有代价的,比如运算操作不准确等,这些就需要我们更加深度的学习。


相关文章
|
4天前
|
JSON Java Apache
非常实用的Http应用框架,杜绝Java Http 接口对接繁琐编程
UniHttp 是一个声明式的 HTTP 接口对接框架,帮助开发者快速对接第三方 HTTP 接口。通过 @HttpApi 注解定义接口,使用 @GetHttpInterface 和 @PostHttpInterface 等注解配置请求方法和参数。支持自定义代理逻辑、全局请求参数、错误处理和连接池配置,提高代码的内聚性和可读性。
|
3天前
|
安全 Java 开发者
深入解读JAVA多线程:wait()、notify()、notifyAll()的奥秘
在Java多线程编程中,`wait()`、`notify()`和`notifyAll()`方法是实现线程间通信和同步的关键机制。这些方法定义在`java.lang.Object`类中,每个Java对象都可以作为线程间通信的媒介。本文将详细解析这三个方法的使用方法和最佳实践,帮助开发者更高效地进行多线程编程。 示例代码展示了如何在同步方法中使用这些方法,确保线程安全和高效的通信。
16 9
|
2天前
|
监控 安全 Java
Java中的多线程编程:从入门到实践####
本文将深入浅出地探讨Java多线程编程的核心概念、应用场景及实践技巧。不同于传统的摘要形式,本文将以一个简短的代码示例作为开篇,直接展示多线程的魅力,随后再详细解析其背后的原理与实现方式,旨在帮助读者快速理解并掌握Java多线程编程的基本技能。 ```java // 简单的多线程示例:创建两个线程,分别打印不同的消息 public class SimpleMultithreading { public static void main(String[] args) { Thread thread1 = new Thread(() -> System.out.prin
|
5天前
|
存储 缓存 安全
在 Java 编程中,创建临时文件用于存储临时数据或进行临时操作非常常见
在 Java 编程中,创建临时文件用于存储临时数据或进行临时操作非常常见。本文介绍了使用 `File.createTempFile` 方法和自定义创建临时文件的两种方式,详细探讨了它们的使用场景和注意事项,包括数据缓存、文件上传下载和日志记录等。强调了清理临时文件、确保文件名唯一性和合理设置文件权限的重要性。
13 2
|
4天前
|
安全 Java
Java多线程集合类
本文介绍了Java中线程安全的问题及解决方案。通过示例代码展示了使用`CopyOnWriteArrayList`、`CopyOnWriteArraySet`和`ConcurrentHashMap`来解决多线程环境下集合操作的线程安全问题。这些类通过不同的机制确保了线程安全,提高了并发性能。
|
1月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
40 1
C++ 多线程之初识多线程
|
21天前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
15 3
|
21天前
|
Java 开发者
在Java多线程编程中,选择合适的线程创建方法至关重要
【10月更文挑战第20天】在Java多线程编程中,选择合适的线程创建方法至关重要。本文通过案例分析,探讨了继承Thread类和实现Runnable接口两种方法的优缺点及适用场景,帮助开发者做出明智的选择。
14 2
|
21天前
|
Java
Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口
【10月更文挑战第20天】《JAVA多线程深度解析:线程的创建之路》介绍了Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口。文章详细讲解了每种方式的实现方法、优缺点及适用场景,帮助读者更好地理解和掌握多线程编程技术,为复杂任务的高效处理奠定基础。
27 2
|
21天前
|
Java 开发者
Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点
【10月更文挑战第20天】Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点,重点解析为何实现Runnable接口更具灵活性、资源共享及易于管理的优势。
27 1