src/edu/berkeley/fleet/RegisterShip.java

   1 package edu.berkeley.fleet;
   2
   3 import java.util.*;
   4 import java.io.*;
   5
   6 public class RegisterShip extends Ship {
   7
   8     Inbox  write     = new Inbox("write");
   9     Outbox read      = new Outbox("read");
  10     Outbox writedone = new Outbox("writedone");
  11
  12     int val = 0;
  13
  14     public RegisterShip(Fleet fleet, String name) {
  15         super(fleet, name);
  16     }
  17
  18     public void service() {
  19         while (!write.empty()) {
  20             val = write.remove();
  21             read.flush();
  22             writedone.add(0);
  23         }
  24         if (read.empty())
  25             read.add(val);
  26     }
  27
  28 }