1 31 package org.objectweb.proactive.examples.futurelist; 32 33 import org.apache.log4j.Logger; 34 35 public class BlockedObject implements org.objectweb.proactive.RunActive, java.io.Serializable { 36 37 38 static Logger logger = Logger.getLogger(BlockedObject.class.getName()); 39 40 41 public BlockedObject() { 42 } 43 44 public void runActivity(org.objectweb.proactive.Body body) { 45 org.objectweb.proactive.Service service = new org.objectweb.proactive.Service(body); 47 service.blockingRemoveOldest("go"); 48 logger.info("BlockedObject: Now in service"); 49 service.fifoServing(); 50 } 51 52 53 public void go() { 55 logger.info("BlockedObject: go()"); 56 } 57 58 59 public EmptyFuture createFuture() { 60 return new EmptyFuture(); 61 62 } 63 } 64 | Popular Tags |