1 31 package org.objectweb.proactive.examples.boundedbuffer; 32 33 36 public class Producer extends ConsumerProducer { 37 38 42 public Producer() { 43 } 44 45 46 49 public Producer(ConsumerProducerListener listener, BoundedBuffer buffer) { 50 super("Producer", listener, buffer); 51 } 52 53 54 protected void doStuff(boolean wasSuspended) { 55 if (isSuspended) { 56 if (!wasSuspended) 57 listener.producerStopRunning(); 58 } else { 59 if (wasSuspended) 60 listener.producerStartRunning(); 61 buffer.put(new String ("@" + (int)(Math.random() * 100))); 62 } 64 } 65 } 66 | Popular Tags |