Parallel Processes 2

class Succ implements CSPProcess {

private ChannelInput in;

private ChannelOutput out;

Succ(ChannelInput in,

ChannelOutput out) {

this.in = in;

this.out = out;

}

public void run() {

while (true) {

Integer x=(Integer)in.read();

int res = x.intValue() + 1;

out.write(new Integer(res));

}

}

}

class Nos implements CSPProcess {

private ChannelOutput out;

Nos(ChannelOutput out) {

this.out = out;

}

public void run() {

Channel a = new Channel();

Channel b = new Channel();

Channel c = new Channel();

new Parallel(new CSPProcess[] {

new Prefix(a,b,new Integer(0)),

new Delta(b, c, out),

new Succ(c, a)

}).run();

}

}

Previous slide

Next slide

Back to first slide

View graphic version