大佬教程收集整理的这篇文章主要介绍了Java多线程编程(同步、死锁、生产消费者问题),大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
线程同步概念:是指若干个线程对象并行进行资源的访问时实现的资源处理保护操作;
线程死锁概念:是指两个线程都在等待对方先完成,造成程序的停止的状态;
先了解相应的概念,后面深入理解。
举个例子:还是卖票问题(经典❗)
@H_197_21@package com.xbhog; class myThread implements Runnable {// 定义线程执行类 privatE int ticket = 3;// 总票数为6张 @Override public void run() { while (true) { // 持续卖票 if (this.ticket > 0) { // 还有剩余票 try { Thread.sleep(100); // 模拟网络延迟 } catch (InterruptedException E) { e.printStackTrace(); } //获取当前线程的名字 System.out.println(Thread.currentThread().getName() + "卖票,ticket = " + this.ticket--); } else { System.out.println("***** 票已经卖光了 *****"); break;// 跳出循环 } } } } public class Java多线程核心 { public static void main(String[] args) throws Exception { myThread mt = new myThread(); new Thread(mt, "售票员A").start(); // 开启卖票线程 new Thread(mt, "售票员B").start(); // 开启卖票线程 new Thread(mt, "售票员C").start(); // 开启卖票线程 } }
结果:
第一次随机运行: | 第二次随机运行: |
---|---|
售票员B卖票,ticket = 2售票员C卖票,ticket = 3售票员A卖票,ticket = 3售票员A卖票,ticket = 1售票员B卖票,ticket = -1***** 票已经卖光了 售票员C卖票,ticket = 0 票已经卖光了 票已经卖光了 ***** | 售票员B卖票,ticket = 1***** 票已经卖光了 售票员A卖票,ticket = 3 票已经卖光了 售票员C卖票,ticket = 2 票已经卖光了 ***** |
存在上述原因是因为在代码中两个地方存在多线程访问时出现模糊的问题:
假设现在剩余的票数为1张;当第一个线程满足售票的条件的时候(此时还未减少票数),其他的线程也可能同时满足售票的条件,这样同时进行自减减就可能造成负数!
解决上述问题就需要采用线程同步技术实现;
首先需要明确,在Java中实现线程同步(synchronized)的方法有两个:
同步代码块(同步策略加在方法内部)
@H_197_21@package com.xbhog.多线程1; class myThread implements Runnable { // 定义线程执行类 privatE int ticket = 3; // 总票数为6张 @Override public void run() { while (true) { // 持续卖票 synchronized(this) { // 同步代码块 if (this.ticket > 0) { // 还有剩余票 try { Thread.sleep(100); // 模拟网络延迟 } catch (InterruptedException E) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "卖票,ticket = " + this.ticket--); } else { System.out.println("***** 票已经卖光了 *****"); break; // 跳出循环 } } } } } public class Java多线程同步代码块 { public static void main(String[] args) { myThread mt = new myThread(); new Thread(mt, "售票员A").start(); // 开启卖票线程 new Thread(mt, "售票员B").start(); // 开启卖票线程 new Thread(mt, "售票员C").start(); // 开启卖票线程 } }
@H_197_21@售票员A卖票,ticket = 3 售票员C卖票,ticket = 2 售票员B卖票,ticket = 1 ***** 票已经卖光了 ***** ***** 票已经卖光了 ***** ***** 票已经卖光了 *****
同步方法(同步策略加在方法上)
@H_197_21@class myThread implements Runnable { // 定义线程执行类 privatE int ticket = 3; // 总票数为6张 @Override public void run() { while (this.SALE()) { // 调用同步方法 ; } } public synchronized Boolean SALE() { // 售票操作 if (this.ticket > 0) { try { Thread.sleep(100); // 模拟网络延迟 } catch (InterruptedException E) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "卖票,ticket = " + this.ticket--); return true; } else { System.out.println("***** 票已经卖光了 *****"); return false; } } } public class ThreadDemo { public static void main(String[] args) throws Exception { myThread mt = new myThread(); new Thread(mt, "售票员A").start(); // 开启卖票线程 new Thread(mt, "售票员B").start(); // 开启卖票线程 new Thread(mt, "售票员C").start(); // 开启卖票线程 } }
@H_197_21@售票员A卖票,ticket = 3 售票员C卖票,ticket = 2 售票员B卖票,ticket = 1 ***** 票已经卖光了 ***** ***** 票已经卖光了 ***** ***** 票已经卖光了 *****
同步的本质:在同一个时间段只允许有一个线程执行资源,所以在此线程对象未执行完的过程中其他线程对象将处于等待的状态。
同步的优点与缺点:
可以保证数据的准确性
数据线程的访问安全
程序的处理性能下降
实例:
假如现在又张三想要李四的画,李四想要张三的书,那么张三对李四说:把你的画给我,我就给你书;
此时:张三在等待李四,李四在等待张三,两人一直等待下去形成死锁;
@H_197_21@package com.xbhog.死锁; class Book { public synchronized void tell(PainTing paint) { // 同步方法 System.out.println("张三对李四说:把你的画给我,我就给你书,不给画不给书!"); paint.get(); } public synchronized void get() { // 同步方法 System.out.println("张三得到了李四的画开始认真欣赏。"); } } class PainTing { public synchronized void tell(Book book) { // 同步方法 System.out.println("李四对张三说:把你的书给我,我就给你画,不给书不给画!"); book.get(); } public synchronized void get() { // 同步方法 System.out.println("李四得到了张三的书开始认真阅读。"); } } public class DeadLock implements Runnable{ private Book book = new Book(); private PainTing paint = new PainTing(); public DeadLock() { new Thread(this).start(); book.tell(paint); } @Override public void run() { paint.tell(book); } public static void main(String[] args) { new DeadLock() ; } }
由于现在电脑的配置问题,该代码有可能在一次运行中展示不出效果来,需要多次运行观察效果;
效果图:
由此引申出了生产者与消费者模型。
首先需要明确生产者与消费者为两个线程对象,是对同一资源进行数据的保存与读取;
基本操作是:生产者生产一个资源,消费者则取走一个资源,一一对应。
对应类关系图:
我们需要设想一个问题,如果不加任何操作的话,会出现什么问题?
解决以上两个问题需要涉及到以下两个知识点:
设置同步代码块或设置同步方法>>>解决数据错误问题
Object线程等待与唤醒>>>解决数据重复设置以及重复取出的问题
在本程序中,生产者与消费者代表的都是线程对象,所以同步操作只能在message类中,可以将set与get方法设置为单独的同步方法。
@H_197_21@class message { private String title ; // 保存信息的标题 private String content ; // 保存信息的内容 public synchronized void set(String title, String content) { this.title = title; try { Thread.sleep(200); } catch (InterruptedException E) { e.printStackTrace(); } this.content = content; } public synchronized String get() { try { Thread.sleep(100); } catch (InterruptedException E) { e.printStackTrace(); } return this.title + " --> " + this.content; } // setter、getter略 } class Producer implements Runnable { // 定义生产者 private message msg = null ; public Producer(message msg) { this.msg = msg ; } @Override public void run() { for (int x = 0; x < 50; x++) { // 生产50次数据 if (x % 2 == 0) { this.msg.set("xbhog","22") ; // 设置属性 } else { this.msg.set("xbhog","www.cnblog.cn/xbhog") ; // 设置属性 } } } } class Consumer implements Runnable { // 定义消费者 private message msg = null ; public Consumer (message msg) { this.msg = msg ; } @Override public void run() { for (int x = 0; x < 50; x++) { // 取走50次数据 System.out.println(this.msg.get()); // 取得属性 } } } public class ThreadDemo { public static void main(String[] args) throws Exception { message msg = new message() ; // 定义message对象,用于保存和取出数据 new Thread(new Producer(msg)).start() ; // 启动生产者线程 new Thread(new Consumer(msg)).start() ; // 取得消费者线程 } }
线程的等待与唤醒只能依靠Object来完成,如果想要让生产者与消费者一个一个拿,一个一个取,那么需要加入标志位来确定线程的当前状态;
由图所示:
当生产者线程与消费者线程进入时,判断当前的标志位是否为true,
true:表示生产者可以生产资源,但是消费者不能取走资源
false:表示生产者不能生产资源,但是消费者需要取走资源
@H_197_21@class message { private String title ; private String content ; private Boolean flag = true; // 表示生产或消费的形式 // flag = true:允许生产,但是不允许消费 // flag = false:允许消费,不允许生产 public synchronized void set(String title,String content) { if (this.flag == falsE) { // 无法进行生产,等待被消费 try { super.wait(); } catch (InterruptedException E) { e.printStackTrace(); } } this.title = title ; try { Thread.sleep(100); } catch (InterruptedException E) { e.printStackTrace(); } this.content = content ; this.flag = false ; // 已经生产过了 super.notify(); // 唤醒等待的线程 } public synchronized String get() { if (this.flag == truE) { // 还未生产,需要等待 try { super.wait(); } catch (InterruptedException E) { e.printStackTrace(); } } try { Thread.sleep(10); } catch (InterruptedException E) { e.printStackTrace(); } try { return this.title + " - " + this.content ; } finally { // 不管如何都要执行 this.flag = true ; // 继续生产 super.notify(); // 唤醒等待线程 } } }
在本程序中追加一个数据产生与消费的控制逻辑成员属性,通过此程序的值控制实现线程的等待与唤醒处理操作,从而解决线程重复操作的问题。
以上是大佬教程为你收集整理的Java多线程编程(同步、死锁、生产消费者问题)全部内容,希望文章能够帮你解决Java多线程编程(同步、死锁、生产消费者问题)所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。