线程通信是通讯通俗指多个线程之间通过某种机制进行协调和交互,例如,易懂线程等待和通知机制就是线程线程通讯的主要手段之一。
在 Java 中,通讯通俗线程等待和通知的易懂实现手段有以下几种方式:
为什么一个线程等待和通知机制就需要这么多的易懂实现方式呢?
别着急,咱们先来看实现,线程再来说原因。通讯通俗
Object 类的方法说明:
示例代码如下:
Object lock = new Object();// 创建线程并执行new Thread(() -> { System.out.println("线程1:开始执行"); synchronized (lock) { try { System.out.println("线程1:进入等待"); lock.wait(); System.out.println("线程1:继续执行"); Thread.sleep(3000); } catch (InterruptedException e) { throw new RuntimeException(e); } System.out.println("线程1:执行完成"); }}).start();Thread.sleep(1000);synchronized (lock) { // 唤醒线程 System.out.println("执行 notifyAll()"); lock.notifyAll();}
Condition 类的方法说明:
示例代码如下:
// 创建 Condition 对象Lock lock = new ReentrantLock();Condition condition = lock.newCondition(); // lock 下可创建多个 Condition// 加锁lock.lock();try { // 业务方法...... // 1.进入等待状态 condition.await(); // 2.唤醒操作 condition.signal();} catch (InterruptedException e) { e.printStackTrace();} finally { lock.unlock();}
LockSupport 类的方法说明:
PS:LockSupport 无需配锁(synchronized 或 Lock)一起使用。
示例代码如下:
public static void main(String[] args) throws InterruptedException { Thread t1 = new Thread(() -> { LockSupport.park(); System.out.println("线程1"); }, "线程1"); t1.start(); Thread t2 = new Thread(() -> { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("唤醒线程1"); LockSupport.unpark(t1); }, "线程2"); t2.start();}
为什么一个线程等待和唤醒的功能需要这么多的实现呢?
// 创建 Condition 对象private Lock lock = new ReentrantLock();// 生产者的 Condition 对象private Condition producerCondition = lock.newCondition();// 本篇内容出自磊哥《Java面试突击训练营》 VX:GG_Stone// 消费者的 Condition 对象private Condition consumerCondition = lock.newCondition();
也就是 Condition 是 Object 等待唤醒模型的升级,Object 类可以实现的功能它都能实现,但 Condition 能实现的功能,Object 却不能实现,这就是 Condition 类存在的必要性。
责任编辑:武晓燕 来源: Java中文社群 Objectwaitnotify那问题来了,为什么还有会 Object 的 wait 和 notify 方法呢?因为 Object 类诞生的比较早,也就是说 Condition 和 LockSupport 都是 JDK 后期版本才出现的功能,所以就有了现在这么多线程唤醒和等待的方法了。
(责任编辑:综合)
2021年前三季度国内旅游总人次26.89亿 旅游收入2.37万亿元
腾讯安全联队Pwn2Own黑客大赛5秒攻破苹果Safari获全额积分
智城云业内首发:嵌入加密芯片的安全WiFi模组MT0300S