怎么在java中实现线程间通信

  

这篇文章将为大家详细讲解有关怎么在java中实现线程间通信,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。

线程间通信:由于多线程共享地址空间和数据空间,所以多个线程间的通信是一个线程的数据可以直接提供给其他线程使用,而不必通过操作系统(也就是内核的调度)。

进程间的通信则不同,它的数据空间的独立性决定了它的通信相对比较复杂,需要通过操作系统。以前进程间的通信只能是单机版的,现在操作系统都继承了基于套接字(socket)的进程间的通信机制。这样进程间的通信就不局限于单台计算机了,实现了网络通信。线程通信主要分为以下几个部分,下面通过生活中图书馆借书的例子简单讲解以下:

通过共享对象通信

加入图书馆只有一本《java并发编程实战》,小A早上的时候把这本书给借走了,然后下午小B去图书馆去找这本书,这时候小A和小B是两个线程,《java并发编程实战》就是共享对象(类似于多线程中的全局变量的资源),小B发现这本书已经被借走了,所以就回去等了几天,几天后,小B又去图书馆发现这本书被还回来了,就把书借走了,这就是通过共享对象进行通信。

忙等待

由于快要BAT实习生招聘了,所以小B非常想看这本书,所以小B就每隔一个小时(while循环)就去看看这本书有没有被还回来了,这样虽然比较耗费处理器资源,但是只要书一旦被还回来,小B就可以马上知道。

wait() notify() notifyAll()

由于图书馆隔着宿舍比较近,所以小B发现每隔一个小时就去图书馆身体有点吃不消,不过很快,学校的图书馆系统增加了短信提醒功能(notify()),所以小B可以一边睡觉一边等短信。

丢失的信号

图书馆系统是这么设计的,当有一本书被还回来的时候,就会给等待者发短信,但是短信只能发送一次,如果没有等待者,短信也会发出(只不过这个时候没有没有接受者),问题出现了,因为短信只会发一次,当书被还回来的时候,没有人等待借书,他会发一条空短信,但是之后有等待借此本书的同学永远也不会再收到短信,导致这些同学会无休止的等待。为了解决这个问题,我们要进入等待状态的时候先打电话问问图书馆阿姨是否需要继续等待。

假唤醒

图书馆系统有一个bug,会是不是给用户发送错误短信,我们很听话,收到短信就会去图书馆借书,但是到达图书馆后发现书根本就没有被还回来,然后接着做其他的事情。

线程间的通信方式

#锁机制:包括互斥锁、条件变量、读写锁

*互斥锁提供了以排他方式防止数据结构被并发修改的方法。

*读写锁允许多个线程同时读共享数据,而对写操作是互斥的。

*条件变量可以以原子的方式阻塞进程,直到某个特定条件为真为止。对条件的测试是在互斥锁的保护下进行的。条件变量始终与互斥锁一起使用。

#信号量机制(Semaphore):包括无名线程信号量和命名线程信号量

#信号机制(Signal):类似进程间的信号处理

线程间的通信目的主要是用于线程同步,所以线程没有像进程通信中的用于数据交换的通信机制。

我觉得我对线程通信的理解还是不够彻底,下面分享几段代码,帮助理解:

①同步

这里讲的同步是指多个线程通过synchronized关键字这种方式来实现线程间的通信。

参考示例:

public class MyObject {
  synchronized  public  void  methodA (), {//do 一些....
  }
  synchronized  public  void  methodB (), {//do  some  other 事情
  }
  }
  public  class  ThreadA  extends  Thread  {
  private  MyObject 对象;//省略构造方法
  @Override
  ,public  void  run (), {
  super.run ();
  object.methodA ();
  }
  }
  public  class  ThreadB  extends  Thread  {
  private  MyObject 对象;//省略构造方法
  @Override
  ,public  void  run (), {
  super.run ();
  object.methodB ();
  }
  }
  public  class  Run  {
  public  static  void  main (String [], args), {
  MyObject  object =, new  MyObject ();//线程一个与线程B 持有的是同一个对象:对象
  ThreadA  a =, new  ThreadA(对象);
  ThreadB  b =, new  ThreadB(对象);
  a.start ();
  b.start ();
  }
  }

怎么在java中实现线程间通信