1 31 package org.objectweb.proactive.examples.boundedbuffer; 32 33 36 public class Consumer extends ConsumerProducer { 37 38 42 public Consumer() { 43 } 44 45 46 49 public Consumer(ConsumerProducerListener listener, BoundedBuffer buffer) { 50 super("Consumer", listener, buffer); 51 } 52 53 54 protected void doStuff(boolean wasSuspended) { 55 if (isSuspended) { 56 if (!wasSuspended) 57 listener.consumerStopRunning(); 58 } else { 59 if (wasSuspended) 60 listener.consumerStartRunning(); 61 buffer.get(); } 64 } 65 } | Popular Tags |