- Timestamp:
- 09/10/13 21:11:41 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/experiment/WorkPackageLogic.java
r103 r105 8 8 import org.apache.logging.log4j.LogManager; 9 9 10 import com.framsticks.core.Message;11 import com.framsticks.core.ValueChange;12 10 import com.framsticks.params.EventListener; 13 11 import com.framsticks.params.MessageLogger; … … 15 13 import com.framsticks.params.annotations.FramsClassAnnotation; 16 14 import com.framsticks.params.annotations.ParamAnnotation; 15 import com.framsticks.structure.messages.Message; 16 import com.framsticks.structure.messages.ValueChange; 17 import com.framsticks.util.dispatching.FutureHandler; 17 18 import com.framsticks.util.dispatching.Future; 18 import com.framsticks.util.dispatching.FutureHandler;19 19 20 20 @FramsClassAnnotation(order = {"netLoadSaveLogic", "newestTaskScheduled", "newestResultReceived"}) … … 47 47 48 48 @Override 49 public void netload(final Simulator simulator, final Future <WP> netFuture) {49 public void netload(final Simulator simulator, final FutureHandler<WP> netFuture) { 50 50 assert experiment.isActive(); 51 51 log.debug("providing netload file for {}", simulator); 52 52 53 findNextPackage(new Future Handler<WP> (netFuture) {53 findNextPackage(new Future<WP> (netFuture) { 54 54 55 55 @Override … … 106 106 107 107 108 protected void findNextPackage(final Future <WP> future) {108 protected void findNextPackage(final FutureHandler<WP> future) { 109 109 if (!queuedPackages.isEmpty()) { 110 110 WP workPackage = queuedPackages.pollFirst(); … … 113 113 } 114 114 115 generateNextPackage(new Future Handler<WP>(experiment) {115 generateNextPackage(new Future<WP>(experiment) { 116 116 117 117 @Override … … 127 127 } 128 128 129 protected abstract void generateNextPackage(Future <WP> future);129 protected abstract void generateNextPackage(FutureHandler<WP> future); 130 130 protected abstract void returnPackage(WP workPackage); 131 131
Note: See TracChangeset
for help on using the changeset viewer.