并发编程系列教程(06) - 多线程之间通讯(wait、notify、sleep、Lock锁、Condition)

简介: 并发编程系列教程(06) - 多线程之间通讯(wait、notify、sleep、Lock锁、Condition)

代码已上传到Github,有兴趣的同学可以下载来看(https://github.com/ylw-github/Java-ThreadDemo

1. 什么是多线程之间通讯?

多线程之间通讯,其实就是多个线程在操作同一个资源,但是操作的动作不同。

2. 多线程之间的通讯需求

需求:第一个线程写入(input)用户,另一个线程取读取(out)用户,实现读一个,写一个操作。

3. 代码实现

package com.ylw.thread;
public class ThreadMsgDemo {
    //1.共享资源实体类
    public static class Res {
        private String userName;
        private String sex;
    }
    //2.读取线程
    public static class InThread extends Thread {
        private Res res;
        int count = 0;
        public InThread(Res res) {
            this.res = res;
        }
        @Override
        public void run() {
            super.run();
            while (true) {
                if (count == 0) {
                    res.userName = "小明";
                    res.sex = "男";
                } else {
                    res.userName = "小红";
                    res.sex = "女";
                }
                count = (count + 1) % 2;
            }
        }
    }
    //3.写入线程
    public static class OutThread extends Thread {
        private Res res;
        public OutThread(Res res) {
            this.res = res;
        }
        @Override
        public void run() {
            super.run();
            while (true) {
                System.out.println(res.userName + "----" + res.sex);
            }
        }
    }
    public static void main(String[] args) {
        Res res = new Res();
        InThread inThread = new InThread(res);
        OutThread outThread = new OutThread(res);
        inThread.start();
        outThread.start();
    }
}

运行结果,会发现数据发生错乱,造成线程安全的问题:

3.1 解决线程安全问题

输入和输出线程加上同步synchronized,如下代码:

//2.读取线程
public static class InThread extends Thread {
    private Res res;
    int count = 0;
    public InThread(Res res) {
        this.res = res;
    }
    @Override
    public void run() {
        super.run();
        while (true) {
            synchronized (res){//同步加锁,解决多线程安全问题
                if (count == 0) {
                    res.userName = "小明";
                    res.sex = "男";
                } else {
                    res.userName = "小红";
                    res.sex = "女";
                }
                count = (count + 1) % 2;
            }
        }
    }
}
//3.写入线程
public static class OutThread extends Thread {
    private Res res;
    public OutThread(Res res) {
        this.res = res;
    }
    @Override
    public void run() {
        super.run();
        while (true) {
            synchronized (res){//同步加锁,解决多线程安全问题
                System.out.println(res.userName + "----" + res.sex);
            }
        }
    }
}

运行结果,正常:

4. wait、notify方法

1.因为涉及到对象锁,他们必须都放在synchronized中来使用。 wait、notify一定要在synchronized里面进行使用。

2.wait: 必须暂定当前正在执行的线程,并释放资源锁,让其他线程可以有机会运行

3.notify/notifyall: 唤醒因锁池中的线程,使之运行

注意:一定要在线程同步中使用,并且是同一个锁的资源。

public class WaitNotifyDemo {
    //1.共享资源实体类
    public static class Res {
        private String userName;
        private String sex;
        private boolean flag = false;//线程间通讯标志
    }
    //2.读取线程
    public static class InThread extends Thread {
        private Res res;
        int count = 0;
        public InThread(Res res) {
            this.res = res;
        }
        @Override
        public void run() {
            super.run();
            while (true) {
                synchronized (res){//同步加锁,解决多线程安全问题
                    if(res.flag){
                        try {
                            res.wait();//暂定当前正在执行的线程,并释放资源锁
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    if (count == 0) {
                        res.userName = "小明";
                        res.sex = "男";
                    } else {
                        res.userName = "小红";
                        res.sex = "女";
                    }
                    count = (count + 1) % 2;
                    res.flag = true;
                    res.notify();//唤醒因锁池中的线程,使之运行
                }
            }
        }
    }
    //3.写入线程
    public static class OutThread extends Thread {
        private Res res;
        public OutThread(Res res) {
            this.res = res;
        }
        @Override
        public void run() {
            super.run();
            while (true) {
                synchronized (res){//同步加锁,解决多线程安全问题
                    if(!res.flag){
                        try {
                            res.wait();//暂定当前正在执行的线程,并释放资源锁
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    System.out.println(res.userName + "----" + res.sex);
                    res.flag = false;
                    res.notify();//唤醒因锁池中的线程,使之运行
                }
            }
        }
    }
    public static void main(String[] args) {
        Res res = new Res();
        InThread inThread = new InThread(res);
        OutThread outThread = new OutThread(res);
        inThread.start();
        outThread.start();
    }
}

运行结果:

5. wait与sleep区别

  1. 对于sleep()方法,我们首先要知道该方法是属于Thread类中的。而wait()方法,则是属于Object类中的。
  2. sleep() 方法导致了程序暂停执行指定的时间,让出cpu给其他线程,但是他的监控状态依然保持者,当指定的时间到了又会自动恢复运行状态。
  3. 在调用sleep()方法的过程中,线程不会释放对象锁。
  4. 而当调用wait()方法的时候,线程会放弃对象锁,进入等待此对象的等待锁定池,只有针对此对象调用notify()方法后本线程才进入对象锁定池准备获取对象锁进入运行状态。

6. Lock锁

在 jdk1.5 之后,并发包中新增了 Lock 接口(以及相关实现类)用来实现锁功能,Lock 接口提供了与 synchronized 关键字类似的同步功能,但需要在使用时手动获取锁和释放锁。

Lock写法:

Lock lock  = new ReentrantLock();
lock.lock();
try{
  //可能会出现线程安全的操作
}finally{
  //一定在finally中释放锁
  //也不能把获取锁在try中进行,因为有可能在获取锁的时候抛出异常
  lock.ublock();
}

Lock与synchronized 关键字的区别:

  1. Lock 接口可以尝试非阻塞地获取锁 当前线程尝试获取锁。如果这一时刻锁没有被其他线程获取到,则成功获取并持有锁。
  2. Lock 接口能被中断地获取锁 与 synchronized 不同,获取到锁的线程能够响应中断,当获取到的锁的线程被中断时,中断异常将会被抛出,同时锁会被释放。
  3. Lock 接口在指定的截止时间之前获取锁,如果截止时间到了依旧无法获取锁,则返回。

7. Condition用法

Condition 的功能类似于在传统的线程技术中的,Object.wait()Object.notify()的功能。

完整代码,Lock与Condition的联和使用:

package com.ylw.thread;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class LockConditionDemo {
    //1.共享资源实体类
    public static class Res {
        private String userName;
        private String sex;
        private boolean flag = false;//线程间通讯标志
        private Lock lock = new ReentrantLock();
    }
    //2.读取线程
    public static class InThread extends Thread {
        private Res res;
        private Condition condition;
        private int count = 0;
        public InThread(Res res, Condition condition) {
            this.res = res;
            this.condition = condition;
        }
        @Override
        public void run() {
            super.run();
            while (true) {
                try {
                    res.lock.lock();
                    if(res.flag){
                        condition.await();
                    }
                    if (count == 0) {
                        res.userName = "小明";
                        res.sex = "男";
                    } else {
                        res.userName = "小红";
                        res.sex = "女";
                    }
                    count = (count + 1) % 2;
                    res.flag = true;
                    condition.signal();
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    res.lock.unlock();
                }
            }
        }
    }
    //3.写入线程
    public static class OutThread extends Thread {
        private Res res;
        private Condition condition;
        public OutThread(Res res, Condition condition) {
            this.res = res;
            this.condition = condition;
        }
        @Override
        public void run() {
            super.run();
            while (true) {
                try {
                    res.lock.lock();
                    if(!res.flag){
                        condition.await();
                    }
                    System.out.println(res.userName + "----" + res.sex);
                    res.flag = false;
                    condition.signal();
                }catch (Exception e){
                    e.printStackTrace();
                }finally {
                    res.lock.unlock();
                }
            }
        }
    }
    public static void main(String[] args) {
        Res res = new Res();
        Condition condition = res.lock.newCondition();
        InThread inThread = new InThread(res,condition);
        OutThread outThread = new OutThread(res,condition);
        inThread.start();
        outThread.start();
    }
}

总结

目录
相关文章
|
4天前
|
安全 Java 开发者
深入解读JAVA多线程:wait()、notify()、notifyAll()的奥秘
在Java多线程编程中,`wait()`、`notify()`和`notifyAll()`方法是实现线程间通信和同步的关键机制。这些方法定义在`java.lang.Object`类中,每个Java对象都可以作为线程间通信的媒介。本文将详细解析这三个方法的使用方法和最佳实践,帮助开发者更高效地进行多线程编程。 示例代码展示了如何在同步方法中使用这些方法,确保线程安全和高效的通信。
23 9
|
5天前
|
并行计算 数据处理 调度
Python中的并发编程:探索多线程与多进程的奥秘####
本文深入探讨了Python中并发编程的两种主要方式——多线程与多进程,通过对比分析它们的工作原理、适用场景及性能差异,揭示了在不同应用需求下如何合理选择并发模型。文章首先简述了并发编程的基本概念,随后详细阐述了Python中多线程与多进程的实现机制,包括GIL(全局解释器锁)对多线程的影响以及多进程的独立内存空间特性。最后,通过实例演示了如何在Python项目中有效利用多线程和多进程提升程序性能。 ####
|
7天前
|
Java
JAVA多线程通信:为何wait()与notify()如此重要?
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是实现线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件满足时被唤醒,从而确保数据一致性和同步。相比其他通信方式,如忙等待,这些方法更高效灵活。 示例代码展示了如何在生产者-消费者模型中使用这些方法实现线程间的协调和同步。
21 3
|
22天前
|
安全 Java
Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧
【10月更文挑战第20天】Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧,包括避免在循环外调用wait()、优先使用notifyAll()、确保线程安全及处理InterruptedException等,帮助读者更好地掌握这些方法的应用。
15 1
|
22天前
|
Java
在Java多线程编程中,`wait()`和`notify()`方法的相遇如同一场奇妙的邂逅
在Java多线程编程中,`wait()`和`notify()`方法的相遇如同一场奇妙的邂逅。它们用于线程间通信,使线程能够协作完成任务。通过这些方法,生产者和消费者线程可以高效地管理共享资源,确保程序的有序运行。正确使用这些方法需要遵循同步规则,避免虚假唤醒等问题。示例代码展示了如何在生产者-消费者模型中使用`wait()`和`notify()`。
23 1
|
22天前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
33 1
|
1月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
41 1
C++ 多线程之初识多线程
|
22天前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
16 3
|
22天前
|
Java 开发者
在Java多线程编程中,选择合适的线程创建方法至关重要
【10月更文挑战第20天】在Java多线程编程中,选择合适的线程创建方法至关重要。本文通过案例分析,探讨了继承Thread类和实现Runnable接口两种方法的优缺点及适用场景,帮助开发者做出明智的选择。
15 2
|
22天前
|
Java
Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口
【10月更文挑战第20天】《JAVA多线程深度解析:线程的创建之路》介绍了Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口。文章详细讲解了每种方式的实现方法、优缺点及适用场景,帮助读者更好地理解和掌握多线程编程技术,为复杂任务的高效处理奠定基础。
28 2