Parallel Processes 3

private ChannelInput in;

private ChannelOutput out1;

private ChannelOutput out2;

public Delta(ChannelInput in, ChannelOutput out1, ChannelOutput out2) {

this.in = in;

this.out1 = out1;

this.out2 = out2;

}

public void run() {

ParWrite[] parWrite = {new ParWrite(out1), new ParWrite(out2)};

Parallel par=new Parallel(parWrite);

while(true) {

Object object = in.read();

parWrite[0].object = object; parWrite[1].object = object;

par.run();

}