Java编程之多线程死锁与线程间通信简单实现代码

更新时间：2017年10月26日 14:09:05 作者：yongxiHU

这篇文章主要介绍了Java编程之多线程死锁与线程间通信简单实现代码，具有一定参考价值，需要的朋友可以了解下。

死锁定义

死锁是指两个或者多个线程被永久阻塞的一种局面，产生的前提是要有两个或两个以上的线程，并且来操作两个或者多个以上的共同资源；我的理解是用两个线程来举例，现有线程A和B同时操作两个共同资源a和b，A操作a的时候上锁LockA,继续执行的时候，A还需要LockB进行下面的操作，这个时候b资源在被B线程操作，刚好被上了锁LockB，假如此时线程B刚好释放了LockB则没有问题，但没有释放LockB锁的时候，线程A和B形成了对LockB锁资源的争夺，从而造成阻塞，形成死锁；具体其死锁代码如下：

public class MyDeadLockTest {
 public static void main(String[] args){
  Object obj1 = new Object();
  Thread thread1 = new Thread(new DeadRes(true,obj1));
  Thread thread2 = new Thread(new DeadRes(false,obj1));
  thread1.start();
  thread2.start();
 }
}
class DeadRes implements Runnable{
 boolean flag;
 Object obj;
 public DeadRes(boolean flag, Object obj1) {
  this.flag = flag;
  this.obj = obj1;
 }
 @Override
 public void run() {
   if(flag){
    synchronized (DeadRes.class){
     System.out.println(Thread.currentThread().getName()+" acquie lock is DeadRes.class");
     synchronized (obj){
      System.out.println(Thread.currentThread().getName()+" acquie lock is obj");
     }
    }
   }else{
    synchronized (obj){
     System.out.println(Thread.currentThread().getName()+" acquie lock is obj");
     synchronized (DeadRes.class){
      System.out.println(Thread.currentThread().getName()+" acquie lock is DeadRes.class");
     }
    }
   }
 }
}

执行结果如下图：

Thread-1 acquie lock is obj
Thread-0 acquie lock is DeadRes.class

当然每次执行的结果不一样，有可能是一种和谐状态，没有发生死锁，此时为保证每次死锁，可以让run()方法中，执行while(true)循环，这样保证了每次必定发生死锁；当然实际应用中，我们应该尽量避免死锁，当有多线程操作多个共同资源的时候，避免发生同一锁对象的同步嵌套。

线程间的通讯—-生产者与消费者模式

1、让两个线程交替进行操作，当生产了一个数字后，紧接着消费一个，首先采用Object对象中的wait-notify来实现，具体代码如下:

public class ThreadProConsume {
 public static void main(String[] args){
  Product product = new Product();
  Thread thread1 = new Thread(new Producer(product));
  Thread thread2 = new Thread(new Consumer(product));
  thread1.start();
  thread2.start();
 }
}
class Product{
 String name;
 private int count = 1;
 boolean flag = false;
 public synchronized void set(String name){
  if(flag){
   try {
    this.wait();
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
  this.name = name +"--"+count++;
  flag = true;
  System.out.println(Thread.currentThread().getName()+" produce num : "+this.name);
  this.notify();
 }
 public synchronized void out(){
  if(!flag){
   try {
    this.wait();
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
  System.out.println(Thread.currentThread().getName()+" consume num is : "+this.name);
  flag = false;
  this.notify();
 }
}
class Producer implements Runnable{
 Product res;
 public Producer(Product product) {
  this.res = product;
 }
 @Override
 public void run() {
  while(true){
   res.set("guyue");
  }
 }
}
class Consumer implements Runnable{
 Product res;
 public Consumer(Product product) {
  this.res = product;
 }
 @Override
 public void run() {
  while(true){
   res.out();
  }
 }
}

执行结果如图：

Thread-1 consume num is : guyue--3938
Thread-0 produce num : guyue--3939
Thread-1 consume num is : guyue--3939
Thread-0 produce num : guyue--3940
Thread-1 consume num is : guyue--3940
Thread-0 produce num : guyue--3941
Thread-1 consume num is : guyue--3941

当超过两个以上线程操作的时候，这里需要在set()与out()方法中的if判断改为while，并且notif方法，改为notifyAll()，这样多个线程操作的时候，便可以交替进行，具体代码如下：

public class ThreadProConsume {
 public static void main(String[] args){
  Product product = new Product();
  Thread thread1 = new Thread(new Producer(product));
  Thread thread3 = new Thread(new Producer(product));
  Thread thread2 = new Thread(new Consumer(product));
  Thread thread4 = new Thread(new Consumer(product));
  thread1.start();
  thread3.start();
  thread2.start();
  thread4.start();
 }
}
class Product{
 String name;
 private int count = 1;
 boolean flag = false;
 public synchronized void set(String name){
  while(flag){
   try {
    this.wait();
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
  this.name = name +"--"+count++;
  flag = true;
  System.out.println(Thread.currentThread().getName()+" produce num : "+this.name);
  this.notifyAll();
 }
 public synchronized void out(){
  while (!flag){
   try {
    this.wait();
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
  System.out.println(Thread.currentThread().getName()+" consume num is : "+this.name);
  flag = false;
  this.notifyAll();
 }
}

执行结果如下：

Thread-0 produce num : guyue--50325
Thread-2 consume num is : guyue--50325
Thread-1 produce num : guyue--50326
Thread-3 consume num is : guyue--50326
Thread-0 produce num : guyue--50327
Thread-2 consume num is : guyue--50327
Thread-1 produce num : guyue--50328
Thread-3 consume num is : guyue--50328

2、采用Lock-Condition方法实现如下：

class Product{
 String name;
 private int count = 1;
 boolean flag = false;
 Lock lock = new ReentrantLock();
 Condition conditon = lock.newCondition();
 public void set(String name){
  try{
   lock.lock();
   while(flag){
    conditon.await();
   }
   this.name = name +"--"+count++;
   flag = true;
   System.out.println(Thread.currentThread().getName()+" produce num : "+this.name);
   conditon.signalAll();
  }catch (Exception e){
  }finally {
   lock.unlock();
  }
 }
 public void out(){
  try{
   lock.lock();
   while(!flag){
    conditon.await();
   }
   flag = false;
   System.out.println(Thread.currentThread().getName()+" consumer num is : "+this.name);
   conditon.signalAll();
  }catch (Exception e){
  }finally {
   lock.unlock();
  }
 }
}

执行结果如下：

Thread-0 produce num : guyue--20305
Thread-3 consumer num is : guyue--20305
Thread-1 produce num : guyue--20306
Thread-2 consumer num is : guyue--20306
Thread-0 produce num : guyue--20307
Thread-3 consumer num is : guyue--20307
Thread-1 produce num : guyue--20308
Thread-2 consumer num is : guyue--20308

以上就是本文关于Java编程之多线程死锁与线程间通信简单实现代码的全部内容，希望对大家有所帮助。关于Java多线程以及线程间通信的例子，本站还有几篇文章可以参考：

详解java中的互斥锁信号量和多线程等待机制、Java多线程编程小实例模拟停车场系统、Java网络编程基础篇之单向通信

如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！

您可能感兴趣的文章:

Java concurrency线程池之线程池原理(四)_动力节点Java学院整理
这篇文章主要为大家详细介绍了Java concurrency线程池之线程池原理，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-06-06
Java FTP协议实现文件下载功能
FTP(File Transfer Protocol)就是文件传输协议。通过FTP客户端从远程FTP服务器上拷贝文件到本地计算机称为下载，将本地计算机上的文件复制到远程FTP服务器上称为上传，上传和下载是FTP最常用的两个功能
2022-11-11
一文带你搞懂Java定时器Timer的使用
定时器类似于我们生活中的闹钟，可以设定一个时间来提醒我们。而定时器是指定一个时间去执行一个任务，让程序去代替人工准时操作。本文就来聊聊Java定时器Timer的使用，需要的可以参考一下
2023-01-01
Java中包装类和Arrays类的详细介绍
Arrays针对于数组做操作的类,该类包含用于操作数组的各种方法(如排序和搜索),这篇文章主要给大家介绍了关于Java中包装类和Arrays类的详细介绍,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2022-12-12
java多线程和并发包入门示例
这篇文章主要写了java多线程的使用方法和java并发包简单入门的示例，大家可以参考使用
2013-11-11
spring动态控制定时任务的实现
在实际项目中,经常需要动态的控制定时任务,比如通过接口增加、启动、停止、删除定时任务,本文主要介绍了spring动态控制定时任务的实现,感兴趣的可以了解一下
2024-01-01
Zookeeper Curator使用介绍
curator是Netﬂix公司开源的⼀套Zookeeper客户端框架，和ZKClient⼀样，Curator解决了很多Zookeeper客户端非常底层的细节开发⼯作，包括连接重连，反复注册Watcher和NodeExistsException异常等，是最流行的Zookeeper客户端之⼀
2022-09-09
手把手教你用Java实现一套简单的鉴权服务
现今大部分系统都会有自己的鉴权服务，本文介绍了最常用的鉴权服务，就是日常用户的登录登出，需要的朋友们下面随着小编来一起学习学习吧
2021-05-05
java中mybatis和hibernate的用法总结
在本篇文章里小编给大家整理的是一篇关于java中mybatis和hibernate的用法总结内容，有兴趣的朋友们可以学习参考下。
2021-01-01
Spring + mybatis + mysql使用事物的几种方法总结
这篇文章主要给大家总结介绍了关于Spring + mybatis + mysql使用事物的几种方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2018-05-05

Java编程之多线程死锁与线程间通信简单实现代码

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具