Robust/src/ClassLibrary/Barrier.java

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