Thread Processes 2

class Succ extends Thread {

private ChannelInput in;

private ChannelOutput out;

Succ(ChannelInput in,

ChannelOutput out) {

this.in = in;

this.out = out;

start();

}

public void run() {

while (true) {

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

int res = x.intValue() + 1;

out.write(new Integer(res));

}

}

}

class Nos extends Thread {

private ChannelOutput out;

Nos(ChannelOutput out) {

this.out = out;

start();

}

public void run() {

Channel a = new Channel();

Channel b = new Channel();

Channel c = new Channel();

Prefix p = new Prefix(a, b,

new Integer(0));

Delta d = new Delta(b, c, out);

Succ s = new Succ(c, a);

p.join(); d.join(); s.join();

}

}

Previous slide

Next slide

Back to first slide

View graphic version