Welcome 微信登录
编程资源 图片资源库 蚂蚁家优选 PDF转换器 软件资源

软件开发、小程序制作、系统集成与运维、空间租用、硬件开发、视频监控、技术咨询与支持——联系电话：0311-88999002/88999003

首页 / 操作系统 / Linux / Java 多线性读者写者问题

Java 多线性读者写者问题
  1. package namespace;  
  2. class Man   
  3. {  
  4.     String name;  
  5.     String sex;  
  6.     boolean flag=false;//  定义一个开关变量，用来进行读或写的操作   
  7. }  
  8. class Input implements Runnable  
  9. {  
  10.     private Man man;  
  11.     private static  int num=1;//用于控制两次写进去的值不一样   
  12.       
  13.     public Input（Man m）  
  14.     {  
  15.         this.man=m;  
  16.     }  
  17.     public void run（）  
  18.     {  
  19.         while（true）  
  20.             {  
  21.                synchronized（man） {  
  22.                    if（man.flag）//如果flag=true的话，就代表已经写进去值了，所以就要等待   
  23.                        try { man.wait（）;}catch（Exception e） {}  
  24.                          
  25.                    if（num==1）//等待被唤醒之后，下面就要对其进行写的操作了   
  26.                    {  
  27.                         man.name="mike";  
  28.                         man.sex="男";  
  29.                               
  30.                    }else {  
  31.                         man.name="Lily";  
  32.                         man.sex="女";  
  33.                         }  
  34.                    //上面是已经执行完写的动作   
  35.                   
  36.                    man.flag=true;//写完之后，要把flag设置成true ,这代表已经写完，等被读，如果再执行写操作的话，上面flag=true ，就开始了等待了   
  37.                    num=（num+1）%2;  
  38.                    man.notify（）;//   
  39.                       
  40.                }  
  41.                               
  42.             }  
  43.     }  
  44. }  
  45. class Output implements Runnable  
  46. {  
  47.     private Man man;  
  48.     public Output（Man m）  
  49.     {  
  50.         this.man=m;  
  51.     }  
  52.     public void run（）  
  53.     {  
  54.         while（true）  
  55.         {  
  56.             synchronized（man）  
  57.             {  
  58.                 if（！man.flag）  
  59.                        try { man.wait（）;}catch（Exception e） {}  
  60.                        
  61.                 System.out.println（man.name+"...."+man.sex）;  
  62.                 man.flag=false;  
  63.                 man.notify（）;  
  64.                   
  65.               
  66.             }  
  67.         }  
  68.     }  
  69. }  
  70. public class Study  
  71. {  
  72.     public static void main（String args[]）  
  73.     {  
  74.         Man man=new Man（）;  
  75.         Thread t1=new Thread（new Input（man））;  
  76.         Thread t2=new Thread（new Output（man））;  
  77.         t1.start（）;  
  78.         t2.start（）;  
  79.     }  
  80. }  
  81. /* 
  82.  *              多线程读者写者问题 
  83.  *                  线程之间的通信一般都是一段共享数据的操作来进行通信的 
  84.  * 
  85.  *          里面的两个线程就是一个读一个写，然而这两个操作是通过两个线程同时进行的．因此如果线程不同步，将会出现安全性问题 
  86.  *          所谓的安全性问题就是线和写和线和读的结果不一样，出就是读出来的值并不是写进行的那样，这样就出来了安全性问题 
  87.  *问题的解决： 
  88.  *      出现这种同时操作一个对象的问题，就是把它们操作那个对象的代码进行同步 
  89.  *      读者与写者的问题要考虑到两个方面： 
  90.  *              1. 读和写的两个线程要同步 
  91.  *              2. 读和写要写进去一个就读一个 
  92.  * 
  93.  *  
  94.  *  
  95.  * */  
  96.  /*                                             2011/10/23  21:22:20 
  97.   * */  
版权所有©石家庄振强科技有限公司2024 冀ICP备08103738号-5 网站地图