Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public static void main(String[] args){
- Buffer[] buffers;
- One2OneChannelInt[] channelForConsumer;
- One2OneChannelInt[] channelForProducer;
- channelForProducer = Channel.one2oneIntArray(10);
- channelForConsumer = Channel.one2oneIntArray(10);
- ChannelOutputInt[] consumerOut = Channel.getOutputArray(channelForConsumer);
- ChannelOutputInt[] producerOut = Channel.getOutputArray(channelForProducer);
- AltingChannelInputInt[] consumerIn = Channel.getInputArray(channelForConsumer);
- AltingChannelInputInt[] producerIn = Channel.getInputArray(channelForProducer);
- Consumer consumer= new Consumer(consumerIn);
- Producer producer = new Producer(producerOut, producerIn);
- buffers = new Buffer[10];
- for(int i=0;i<buffers.length;i++){
- buffers[i]=new Buffer(channelForProducer[i], consumerOut[i]);
- }
- Parallel parallel = new Parallel();
- for(Buffer b: main.buffers){
- parallel.addProcess(b);
- }
- parallel.addProcess(consumer);
- parallel.addProcess(producer);
- parallel.run();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement