COSC6490A

This page is read only. You can view the source, but not change it. Ask your administrator if you think this is wrong.
<code java>
public class Process implements CSProcess
{
  private ChannelOutput verhoog;
  private ChannelOutput prolaag;

  public Process(ChannelOutput verhoog, ChannelOutput prolaag)
  {
    super();
    this.verhoog = verhoog;
    this.prolaag = prolaag;
  }

  public void run()
  {
    this.prolaag.write(null);
    // critical section
    this.verhoog.write(null);
  }
} 
</code>

<code java>
public class Semaphore implements CSProcess
{
  private int value;
  private AltingChannelInput verhoog;
  private AltingChannelInput prolaag;

  public Semaphore(int value, AltingChannelInput verhoog, AltingChannelInput prolaag)
  {
    super();
    this.value = value;
    this.verhoog = verhoog;
    this.prolaag = prolaag;
  }

  public void run()
  {
    final int ALTERNATIVES = 2;
    final int V = 0;
    final int P = 1;
    final Guard[] guard = new Guard[ALTERNATIVES];
    guard[V] = this.verhoog;
    guard[P] = this.prolaag;
    final boolean[] precondition = new boolean[ALTERNATIVES];
    precondition[V] = true;
    final Alternative alternative = new Alternative(guard);
    while (true)
    {
      precondition[P] = this.value > 0;
      switch (alternative.select(precondition))
      {
        case V:
          this.verhoog.read(); 
          this.value++;
          break;
        case P:
          this.prolaag.read(); 
          this.value--;
          break;
      }
    }
  }
}
</code>

<code java>
public class Main
{
  public static void main(String[] args)
  {
    Any2OneChannel verhoog = Channel.any2one();
    Any2OneChannel prolaag = Channel.any2one();
    Semaphore semaphore = new Semaphore(1, verhoog.in(), prolaag.in());
    Process one = new Process(verhoog.out(), prolaag.out());
    Process two = new Process(verhoog.out(), prolaag.out());
    CSProcess[] process = { semaphore, one, two };
    Parallel parallel = new Parallel(process);
    parallel.run();
  }
}
</code>