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

首页 / 操作系统 / Linux / 用Java实现的第二类读者写者问题

用Java实现的第二类读者写者问题:
  1. //--Semaphore.java</PRE><PRE class=java name="code">package rw;   
  2.   
  3. public class Semaphore {  
  4.     private int value;//记录希望访问临界资源的线程的计数器个数   
  5.       
  6.     public Semaphore（int i）  
  7.     {  
  8.         this.value=i;  
  9.     }  
  10.       
  11.     public synchronized void P（）  
  12.     {  
  13.         value--;  
  14.         if（value<0）  
  15.             try {  
  16.                 wait（）;  
  17.             } catch （InterruptedException e） {  
  18.                 e.printStackTrace（）;  
  19.                 Thread.currentThread（）.interrupt（）;  
  20.             }  
  21.     }  
  22.   
  23.     public synchronized void V（）  
  24.     {  
  25.         value++;  
  26.         if（value<=0）  
  27.         {  
  28.             notifyAll（）;  
  29.         }  
  30.     }  
  31. }</PRE><BR>  
  32. <PRE class=java name="code">//------------------------------文件2  ReaderWriter.java------------------------------------------------   
  33. package rw;  
  34.   
  35. import java.io.FileNotFoundException;  
  36. import java.io.PrintStream;  
  37.   
  38. public class ReaderWriter extends Thread{  
  39.   
  40.     String msg;  
  41.     int NO;  
  42.     final int N=100;  
  43.     static public int num=0;  
  44.     static public int readers=0;  
  45.     static public int writers=0;  
  46.     final static public String base="Last Writer:";  
  47.     static public String resource=base+"0";  
  48.     static Semaphore mutexr=new Semaphore（1）;  
  49.     static Semaphore mutexw=new Semaphore（1）;  
  50.       
  51.     static Semaphore mutex=new Semaphore（1）;  
  52.       
  53.     static Semaphore mutexWrite=new Semaphore（1）;  
  54.       
  55.     public ReaderWriter（）  
  56.     {  
  57.         NO=num++;  
  58.         if（NO%N！=1）  
  59.             msg="I am reader @"+NO;  
  60.         else   
  61.             msg="I am writer @"+NO;  
  62.     }  
  63.       
  64.     public void read（）  
  65.     {  
  66.         if（writers！=0）//如果有写者，阻塞，并且后续的读者不许进来   
  67.             mutex.P（）;  
  68.         mutexr.P（）;  
  69.         readers++;  
  70.         if（readers==1）//保证当读的时候，对写互斥，写者等待   
  71.             mutexWrite.P（）;  
  72.         mutexr.V（）;  
  73.           
  74.         //.............................................读开始...   
  75.         System.out.println（"      "+NO+" is reading, resource=" +resource）;  
  76.         //.............................................读结束...   
  77.           
  78.         mutexr.P（）;  
  79.         readers--;  
  80.         if（readers==0）  
  81.             mutexWrite.V（）;  
  82.         mutexr.V（）;  
  83.         if（writers！=0）//如果有写者，阻塞，并且后续的读者不许进来   
  84.             mutex.V（）;  
  85.     }  
  86.       
  87.     public void write（）  
  88.     {  
  89.           
  90.         mutexw.P（）;  
  91.         writers++;  
  92.         if（writers==1）  
  93.             mutex.P（）;  
  94.         mutexw.V（）;  
  95.           
  96.         //.....................................................写开始   
  97.         mutexWrite.P（）;  
  98.         resource="base"+NO;  
  99.         System.out.println（NO+" IS WRITING, resource=" +resource）;  
  100.         mutexWrite.V（）;  
  101.         //.....................................................写结束   
  102.           
  103.         mutexw.P（）;  
  104.         writers--;  
  105.         if（writers==0）  
  106.             mutex.V（）;  
  107.         mutexw.V（）;  
  108.     }  
  109.       
  110.     public void run（）  
  111.     {  
  112.         int n=1000;  
  113.         while（n-->0）  
  114.         {  
  115.             if（NO%N！=1）  
  116.             {/* 
  117.                 try { 
  118.                     Thread.sleep（1）; 
  119.                 } catch （InterruptedException e） { 
  120.                     // TODO Auto-generated catch block 
  121.                     e.printStackTrace（）; 
  122.                 } 
  123.                 */  
  124.                 read（）;  
  125.             }  
  126.             else   
  127.             {  
  128.                 write（）;  
  129.                 /* 
  130.                 try { 
  131.                     Thread.sleep（100）; 
  132.                 } catch （InterruptedException e） { 
  133.                     // TODO Auto-generated catch block 
  134.                     e.printStackTrace（）; 
  135.                 } 
  136.                 */  
  137.             }  
  138.         }  
  139.     }  
  140.       
  141.     public static void main（String args[]）  
  142.     {  
  143.         PrintStream ps;  
  144.         try {  
  145.             ps = new PrintStream（"D:\readerWriter.txt"）;  
  146.             System.setOut（ps）;  
  147.         } catch （FileNotFoundException e） {  
  148.             e.printStackTrace（）;  
  149.         }  
  150.         for（int i=0;i<1000;i++）  
  151.         {  
  152.             new ReaderWriter（）.start（）;  
  153.         }  
  154.     }  
  155. }
版权所有©石家庄振强科技有限公司2024 冀ICP备08103738号-5 网站地图