Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public static void main(String[] args){
- Buffer[] buffers new Buffer[10];
- Consumer consumer new Consumer(channels[9].in());
- Producer producer new Producer(channels[0].out());
- One2OneChannelInt[] channels = Channel.one2oneIntArray(n);
- for(int i=0;i<buffers.length-1;i++){
- buffers[i]=new Buffer(channels[i].in(), channels[i+1].out());
- }
- Parallel parallel = new Parallel();
- for(Buffer buffer: buffers){
- parallel.addProcess(buffer);
- }
- parallel.addProcess(main.consumer);
- parallel.addProcess(main.producer);
- parallel.run();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement