- Timestamp:
- 09/10/13 21:11:41 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/test/PrimeExperiment.java
r103 r105 8 8 import org.apache.logging.log4j.LogManager; 9 9 10 import com.framsticks.core.ValueChange;11 10 import com.framsticks.experiment.Experiment; 12 11 import com.framsticks.experiment.WorkPackageLogic; … … 15 14 import com.framsticks.params.annotations.FramsClassAnnotation; 16 15 import com.framsticks.params.annotations.ParamAnnotation; 16 import com.framsticks.params.types.ProcedureParam; 17 import com.framsticks.structure.messages.ValueChange; 17 18 import com.framsticks.test.prime.ExpParams; 18 19 import com.framsticks.test.prime.PrimePackage; 19 20 import com.framsticks.util.FramsticksException; 20 import com.framsticks.util.dispatching.Future ;21 import com.framsticks.util.dispatching.FutureHandler; 21 22 22 23 @FramsClassAnnotation … … 33 34 protected int nextWaitNumber = 1; 34 35 protected List<PrimePackage> waitingPackages = new LinkedList<>(); 35 protected List<Integer> primes = new LinkedList<>();36 // protected List<Integer> primes = new LinkedList<>(); 36 37 37 38 protected final EventListeners<ValueChange> primesListeners = new EventListeners<>(); … … 50 51 51 52 @Override 52 protected void generateNextPackage(Future <PrimePackage> future) {53 protected void generateNextPackage(FutureHandler<PrimePackage> future) { 53 54 assert isActive(); 54 55 if (task.state.current_number > task.params.to_number) { … … 84 85 return; 85 86 } 86 log.info("experiment is done, {} primes found", primes.size());87 log.debug("primes: {}", primes);87 log.info("experiment is done, {} primes found", getPrimes().size()); 88 log.debug("primes: {}", getPrimes()); 88 89 } 89 90 }; 91 } 92 93 public List<Integer> getPrimes() { 94 return task.state.getResultList(); 90 95 } 91 96 … … 98 103 } 99 104 100 primes.addAll(result.state.getResultList());105 getPrimes().addAll(result.state.getResultList()); 101 106 nextWaitNumber = result.params.to_number + 1; 102 107 … … 141 146 @ParamAnnotation 142 147 public String getDescription() { 143 return primes.size() + " found in range " + new ExpParams(task.params.from_number, nextWaitNumber - 1);148 return getPrimes().size() + " found in range " + new ExpParams(task.params.from_number, nextWaitNumber - 1); 144 149 } 145 150 … … 154 159 } 155 160 161 @ParamAnnotation(paramType = ProcedureParam.class) 162 public PrimePackage experimentNetsave() { 163 return task; 164 } 165 156 166 }
Note: See TracChangeset
for help on using the changeset viewer.