Robust/src/ClassLibrary/Barrier.java

   1 public class BarrierServer extends Thread {
   2     int numthreads;
   3     boolean done;
   4
   5     public BarrierServer(int n) {
   6         numthreads=n;
   7         done=false;
   8     }
   9
  10     public void run() {
  11         int n;
  12         ServerSocket ss=new ServerSocket(2000);
  13         atomic {
  14             n=numthreads;
  15             done=true;
  16         }
  17         Socket ar[]=new Socket[n];
  18         for(int i=0;i<n;i++) {
  19             ar[i]=ss.accept();
  20         }
  21
  22         while(true) {
  23             for(int j=0;j<n;j++) {
  24                 Socket s=ar[j];
  25                 byte b[]=new byte[1];
  26                 while(s.read(b)!=1) {
  27                     ;
  28         }
  29             }
  30             byte b[]=new byte[1];
  31             b[0]= (byte) 'A';
  32             for(int j=0;j<n;j++)
  33           ar[j].write(b);
  34         }
  35     }
  36 }
  37
  38 public class Barrier {
  39     Socket s;
  40     public Barrier(String name) {
  41         s=new Socket(name, 2000);
  42     }
  43
  44     public static void enterBarrier(Barrier barr) {
  45         byte b[]=new byte[1];
  46         b[0]=(byte)'A';
  47         barr.s.write(b);
  48         while(barr.s.read(b)!=1) {
  49       ;
  50     }
  51     }
  52 }