Advertisement
Guest User

Untitled

a guest
Jan 20th, 2020
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.15 KB | None | 0 0
  1. public static void main(String[] args){
  2.         Buffer[] buffers;
  3.         One2OneChannelInt[] channelForConsumer;
  4.         One2OneChannelInt[] channelForProducer;
  5.        
  6.         channelForProducer = Channel.one2oneIntArray(10);
  7.         channelForConsumer = Channel.one2oneIntArray(10);
  8.         ChannelOutputInt[] consumerOut = Channel.getOutputArray(channelForConsumer);
  9.         ChannelOutputInt[] producerOut = Channel.getOutputArray(channelForProducer);
  10.         AltingChannelInputInt[] consumerIn = Channel.getInputArray(channelForConsumer);
  11.         AltingChannelInputInt[] producerIn = Channel.getInputArray(channelForProducer);
  12.         Consumer consumer= new Consumer(consumerIn);
  13.         Producer producer = new Producer(producerOut, producerIn);
  14.         buffers = new Buffer[10];
  15.  
  16.         for(int i=0;i<buffers.length;i++){
  17.             buffers[i]=new Buffer(channelForProducer[i], consumerOut[i]);
  18.         }
  19.         Parallel parallel = new Parallel();
  20.         for(Buffer b: main.buffers){
  21.             parallel.addProcess(b);
  22.         }
  23.         parallel.addProcess(consumer);
  24.         parallel.addProcess(producer);
  25.         parallel.run();
  26.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement